public
Last active

selectLeader

  • Download Gist
selectLeader.scala
Scala
1 2 3 4 5 6 7 8
def selectLeader() {
leaderLatch = new LeaderLatch(curatorFramework, leaderPath, nodeId)
 
leaderLatch.start()
 
// Optional, only if you need notification on cluster changes
watchLeaderChildren()
}

Please sign in to comment on this gist.

Something went wrong with that request. Please try again.