public

ericacm / selectLeader.scala

Last active 2013-01-21

def selectLeader() {
  leaderLatch = new LeaderLatch(curatorFramework, leaderPath, nodeId)
 
  leaderLatch.start()
 
  // Optional, only if you need notification on cluster changes
  watchLeaderChildren()
}