Skip to content

@ericacm /watchLeaderChildren.scala
Last active

Embed URL

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
watchLeaderChildren
def watchLeaderChildren() {
curatorFramework.getChildren.usingWatcher(
new CuratorWatcher {
def process(event: WatchedEvent) {
val cs = clusterStatus()
// Do something with cluster status (log leadership change, etc)
// Re-set watch
curatorFramework.getChildren.usingWatcher(this).
inBackground.forPath(leaderPath)
}
}).inBackground.forPath(leaderPath)
}
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.