public void connectionClosed(ConnectionClosed connectionClosed) {
connectionBackoff.connectionFailed(getNetwork(connectionClosed.connection()).get());
removeConnection(connectionClosed.connection());
+ synchronized (syncObject) {
+ syncObject.notifyAll();
+ }
eventBus.post(new GenericMessage(String.format("Connection closed by %s.", connectionClosed.connection().hostname())));
}
public void connectionFailed(ConnectionFailed connectionFailed) {
connectionBackoff.connectionFailed(getNetwork(connectionFailed.connection()).get());
removeConnection(connectionFailed.connection());
+ synchronized (syncObject) {
+ syncObject.notifyAll();
+ }
eventBus.post(new GenericMessage(String.format("Could not connect to %s: %s.", connectionFailed.connection().hostname(), connectionFailed.cause())));
}
Optional<Channel> channel = getChannel(network.get(), channelNotJoined.channel());
if (!channel.isPresent()) {
- eventBus.post(new GenericMessage(format("Could not join %s but didn’t try to join, either.", channel.get())));
+ eventBus.post(new GenericMessage(format("Could not join %s but didn’t try to join, either.", channelNotJoined.channel())));
return;
}
channelsBeingJoined.remove(channel.get());
+ synchronized (syncObject) {
+ syncObject.notifyAll();
+ }
/* remove all bots for this channel, we might have been kicked. */
Collection<Bot> botsToRemove = networkBots.row(network.get())
} else {
channels.remove(channel.get());
}
+ synchronized (syncObject) {
+ syncObject.notifyAll();
+ }
eventBus.post(new GenericMessage(String.format("Left Channel %s on %s.", channel.get().name(), channel.get().network().name())));
}
} else {
joinedChannels.remove(channel.get());
}
+ synchronized (syncObject) {
+ syncObject.notifyAll();
+ }
eventBus.post(new GenericMessage(format(
"Kicked from %s by %s: %s",
kickedFromChannel.channel(),