public
Last active

start Zookeeper client

  • Download Gist
zkClientStartup.scala
Scala
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
def initialize() {
// Embedded server startup here (see part 2)
// ...
curatorFramework =
CuratorFrameworkFactory.newClient(
connectString, sessionTimeoutSec*1000,
connectionTimeoutSec*1000, new RetryOneTime(1))
curatorFramework.start()
curatorFramework.getZookeeperClient.blockUntilConnectedOrTimedOut()
if (!curatorFramework.isStarted) {
throw new Exception(
"Connection to Zookeeper timed out after " + connectionTimeoutSec + " seconds")
}
selectLeader()
}

Please sign in to comment on this gist.

Something went wrong with that request. Please try again.