diff --git a/src/main/java/altk/comm/engine/Broadcast.java b/src/main/java/altk/comm/engine/Broadcast.java index deaa349..917f249 100644 --- a/src/main/java/altk/comm/engine/Broadcast.java +++ b/src/main/java/altk/comm/engine/Broadcast.java @@ -1015,30 +1015,6 @@ public abstract class Broadcast // Do nothing in base class } - public void startProcessing() throws BroadcastException - { - effectiveJobCount = recipientList.size(); - - // Create service thread pool to dispatch jobs - myLogger.debug("At creating service threads, serviceThreadPoolSize = " + serviceThreadPoolSize); - for (int i = 0; i < serviceThreadPoolSize; i++) - { - String threadName = broadcastId + "_service_thread_" + i; - Service serviceThread = new Service(threadName); - serviceThreadPool.add(serviceThread); - } - - initServiceThreadContexts(); - - setState(BroadcastState.RUNNING); - - // Start the dispatcher threads - for (Service thread : serviceThreadPool) - { - thread.start(); - } - } - /** * Derived class may set up environment before starting Service threads. * @param serviceThreadNames