Last active

Embed URL

HTTPS clone URL

SSH clone URL

You can clone with HTTPS or SSH.

Download Gist

selectLeader

View selectLeader.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()
}
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.