LOG.debug("Awaiting Connection event from Zookeeper cluster {}", configuration.getConnectString());
}
try {
connectionLatch.await();
} catch (InterruptedException e) {
<BUG>ObjectHelper.wrapRuntimeCamelException(e);
</BUG>
}
}
public void process(WatchedEvent event) {

LOG.debug("Awaiting Connection event from Zookeeper cluster {}", configuration.getConnectString());
}
try {
connectionLatch.await();
} catch (InterruptedException e) {
throw ObjectHelper.wrapRuntimeCamelException(e);
}
}
public void process(WatchedEvent event) {
