@@ -536,6+536,7 @@ public class Core extends AbstractExecutionThreadService {
@Subscribe
public void connectionClosed(ConnectionClosed connectionClosed) {
removeConnection(connectionClosed.connection());
@Subscribe
public void connectionClosed(ConnectionClosed connectionClosed) {
removeConnection(connectionClosed.connection());
+ eventBus.post(new GenericMessage(String.format("Connection closed by %s.", connectionClosed.connection().hostname())));
}
/**
}
/**
@@ -547,6+548,7 @@ public class Core extends AbstractExecutionThreadService {
@Subscribe
public void connectionFailed(ConnectionFailed connectionFailed) {
removeConnection(connectionFailed.connection());
@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())));
}
/**
}
/**
@@ -677,9+679,9 @@ public class Core extends AbstractExecutionThreadService {