/* ignore. */
}
}
+ if (!isRunning()) {
+ break;
+ }
/* find channels that should be monitored but are not. */
for (Channel channel : channels) {
}
@Override
- protected void shutDown() {
+ protected void triggerShutdown() {
synchronized (syncObject) {
syncObject.notifyAll();
}