Skip to content

@ericacm /zkClientStartup.scala
Last active

Embed URL

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
start Zookeeper client
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()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Something went wrong with that request. Please try again.