Skip to content

Instantly share code, notes, and snippets.

Last active October 11, 2015 23:28
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
What would you like to do?
start Zookeeper client
def initialize() {
// Embedded server startup here (see part 2)
// ...
curatorFramework =
connectString, sessionTimeoutSec*1000,
connectionTimeoutSec*1000, new RetryOneTime(1))
if (!curatorFramework.isStarted) {
throw new Exception(
"Connection to Zookeeper timed out after " + connectionTimeoutSec + " seconds")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment