|
|
@ -166,10 +166,9 @@ public class serverProcessor<J extends serverProcessorJob> {
|
|
|
|
if (executor != null & !executor.isShutdown()) {
|
|
|
|
if (executor != null & !executor.isShutdown()) {
|
|
|
|
// wait for shutdown
|
|
|
|
// wait for shutdown
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
executor.shutdown();
|
|
|
|
executor.awaitTermination(millisTimeout, TimeUnit.MILLISECONDS);
|
|
|
|
executor.awaitTermination(millisTimeout, TimeUnit.MILLISECONDS);
|
|
|
|
|
|
|
|
|
|
|
|
} catch (final InterruptedException e) {}
|
|
|
|
} catch (final InterruptedException e) {}
|
|
|
|
executor.shutdown();
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
serverLog.logInfo("serverProcessor", "queue " + this.processName + ": shutdown.");
|
|
|
|
serverLog.logInfo("serverProcessor", "queue " + this.processName + ": shutdown.");
|
|
|
|
this.executor = null;
|
|
|
|
this.executor = null;
|
|
|
|