| @@ -55,7 +55,7 @@ public abstract class Broadcast | |||||
| private PostBack postBack; | private PostBack postBack; | ||||
| public long expireTime; | public long expireTime; | ||||
| static Logger myLogger = Logger.getLogger(Broadcast.class); | |||||
| protected static Logger myLogger = Logger.getLogger(Broadcast.class); | |||||
| /** | /** | ||||
| * This queue is designed for only one server | * This queue is designed for only one server | ||||
| @@ -217,6 +217,7 @@ public abstract class Broadcast | |||||
| public void run() | public void run() | ||||
| { | { | ||||
| myLogger.info("Thread " + getName() + " starting..."); | |||||
| NDC.push(getName()); | NDC.push(getName()); | ||||
| for (;;) | for (;;) | ||||
| { | { | ||||
| @@ -749,6 +750,7 @@ public abstract class Broadcast | |||||
| public void startProcessing() throws BroadcastException | public void startProcessing() throws BroadcastException | ||||
| { | { | ||||
| // Create service thread pool to dispatch jobs | // Create service thread pool to dispatch jobs | ||||
| myLogger.debug("At creating service threads, serviceThreadPoolSize = " + serviceThreadPoolSize); | |||||
| for (int i = 0; i < serviceThreadPoolSize; i++) | for (int i = 0; i < serviceThreadPoolSize; i++) | ||||
| { | { | ||||
| String threadName = broadcastId + "_service_thread_" + i; | String threadName = broadcastId + "_service_thread_" + i; | ||||