|
|
|
@@ -207,11 +207,11 @@ public abstract class Broadcast |
|
|
|
|
|
|
|
protected class Service extends Thread |
|
|
|
{ |
|
|
|
Object serviceProvider; |
|
|
|
Object serviceProviderPeer; |
|
|
|
|
|
|
|
protected Service(String name) throws BroadcastException |
|
|
|
{ |
|
|
|
serviceProvider = getInitializedServiceProvider(); |
|
|
|
serviceProviderPeer = getInitializedServiceProviderPeer(); |
|
|
|
setName(name); |
|
|
|
} |
|
|
|
|
|
|
|
@@ -222,7 +222,7 @@ public abstract class Broadcast |
|
|
|
{ |
|
|
|
if (threadsShouldStop()) |
|
|
|
{ |
|
|
|
closeServiceProvider(serviceProvider); |
|
|
|
closeServiceProvider(serviceProviderPeer); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
@@ -299,7 +299,7 @@ public abstract class Broadcast |
|
|
|
// Service the jobs |
|
|
|
try |
|
|
|
{ |
|
|
|
processJobs(batch, serviceProvider, prerequisites); |
|
|
|
processJobs(batch, serviceProviderPeer, prerequisites); |
|
|
|
completedJobCount++; |
|
|
|
} |
|
|
|
catch (EngineException e) |
|
|
|
@@ -344,7 +344,7 @@ public abstract class Broadcast |
|
|
|
* @return service provider as a class Object instance. |
|
|
|
* @throws BroadcastException |
|
|
|
*/ |
|
|
|
protected abstract Object getInitializedServiceProvider() throws BroadcastException; |
|
|
|
protected abstract Object getInitializedServiceProviderPeer() throws BroadcastException; |
|
|
|
|
|
|
|
/** |
|
|
|
* Obtains the required components to support a service; e.g. RTP port, or a place |
|
|
|
@@ -456,6 +456,10 @@ public abstract class Broadcast |
|
|
|
responseXML.append("'"); |
|
|
|
if (e == null) |
|
|
|
{ |
|
|
|
if (haltReason != null && haltReason.length() > 0) |
|
|
|
{ |
|
|
|
responseXML.append(" error='" + haltReason + "'"); |
|
|
|
} |
|
|
|
responseXML.append('>'); |
|
|
|
} |
|
|
|
else |
|
|
|
|