*/
@Subscribe
public void connectionClosed(ConnectionClosed connectionClosed) {
- removeConnection(connectionClosed.connection());
connectionBackoff.connectionFailed(getNetwork(connectionClosed.connection()).get());
+ 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());
connectionBackoff.connectionFailed(getNetwork(connectionFailed.connection()).get());
+ removeConnection(connectionFailed.connection());
eventBus.post(new GenericMessage(String.format("Could not connect to %s: %s.", connectionFailed.connection().hostname(), connectionFailed.cause())));
}