ericacm / watchLeaderChildren.scala

Last active January 21, 2013

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