watchLeaderChildren

watchLeaderChildren.scala

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)
}