From 2c7ba134d84be4b24619260689a0b07819d2021c Mon Sep 17 00:00:00 2001 From: ymlam Date: Thu, 12 Sep 2019 03:08:28 -0400 Subject: [PATCH] Remove unused startProcessing method. --- src/main/java/altk/comm/engine/Broadcast.java | 24 ------------------- 1 file changed, 24 deletions(-) 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