ericacm / selectLeader.scala

Last active January 21, 2013


    
    View selectLeader.scala 
  
  
      selectLeader.scala
    
    
        Raw
      
    
    File suppressed. Click to show.
  
  
            1
            2
            3
            4
            5
            6
            7
            8
          
          
            def selectLeader() {
  leaderLatch = new LeaderLatch(curatorFramework, leaderPath, nodeId)
 
  leaderLatch.start()
 
  // Optional, only if you need notification on cluster changes
  watchLeaderChildren()
}