void (final ServerConnectionImpl<?> connection) { myEventsQueue.activate(); myEventsQueue.queue(new Update(connection, CONNECTION_STATUS_PRIORITY) { @Override public void run() { myMessageBus.syncPublisher(ServerConnectionListener.TOPIC).onConnectionStatusChanged(connection); } }); }