| 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