}
if (configuration.getConnectString() == null) {
throw new RuntimeCamelException("Cannot create ZooKeeper connection as connection string is null. Have servers been configured?");
}
try {
<BUG>if (configuration.getSessionId() > 0 && configuration.getSessionPassword() != null) {
zookeeper = new ZooKeeper(configuration.getConnectString(), configuration.getTimeout(), this, configuration.getSessionId(), configuration.getSessionPassword());
} else {</BUG>
zookeeper = new ZooKeeper(configuration.getConnectString(), configuration.getTimeout(), this);
<BUG>}</BUG>
} catch (Exception e) {
<BUG>ObjectHelper.wrapRuntimeCamelException(e);
</BUG>
}

}
public ZooKeeper getZooKeeper() {
if (zookeeper != null) {
return zookeeper;
}
if (configuration.getConnectString() == null) {
throw new RuntimeCamelException("Cannot create ZooKeeper connection as connection string is null. Have servers been configured?");
}
try {
zookeeper = new ZooKeeper(configuration.getConnectString(), configuration.getTimeout(), this);
} catch (Exception e) {
throw ObjectHelper.wrapRuntimeCamelException(e);
}
