selectLeader
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