/* 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();
}
@Subscribe
public void connectionClosed(ConnectionClosed connectionClosed) {
removeConnection(connectionClosed.connection());
+ eventBus.post(new GenericMessage(String.format("Connection closed by %s.", connectionClosed.connection().hostname())));
}
/**
@Subscribe
public void connectionFailed(ConnectionFailed connectionFailed) {
removeConnection(connectionFailed.connection());
+ eventBus.post(new GenericMessage(String.format("Could not connect to %s: %s.", connectionFailed.connection().hostname(), connectionFailed.cause())));
}
/**
return;
}
- extraChannels.remove(channel);
+ extraChannels.remove(channel.get());
} else {
- channels.remove(channel.get());
+ joinedChannels.remove(channel.get());
}
eventBus.post(new GenericMessage(format(
"Kicked from %s by %s: %s",