stoppable = CompositeStoppable.stoppable(hub, discoveryBroadcast, executor);
} finally {
connections.clear();
lock.unlock();
}
stoppable.stop();
}
private class DiscoveryMessageDispatch implements Dispatch<DiscoveryMessage> {
public void dispatch(DiscoveryMessage message) {
if (message instanceof ChannelAvailable) {