Package org.apache.storm.nimbus
Class LeaderListenerCallback
java.lang.Object
org.apache.storm.nimbus.LeaderListenerCallback
A callback function when nimbus gains leadership.
- 
Constructor SummaryConstructorsConstructorDescriptionLeaderListenerCallback(Map conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, ILeaderElector leaderElector, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry) Creates aLeaderListenerCallback.
- 
Method SummaryModifier and TypeMethodDescriptionvoidleaderCallBack(Object lock) Invoke when gains leadership.voidInvoke when lost leadership.
- 
Constructor Details- 
LeaderListenerCallbackpublic LeaderListenerCallback(Map conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, ILeaderElector leaderElector, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry) Creates aLeaderListenerCallback.- Parameters:
- conf- config
- zk- zookeeper CuratorFramework client
- blobStore- BlobStore
- leaderElector- Leader elector
- tc- TopoCache
- clusterState- IStormClusterState
- acls- zookeeper acls
 
 
- 
- 
Method Details- 
leaderCallBackInvoke when gains leadership.
- 
notLeaderCallbackpublic void notLeaderCallback()Invoke when lost leadership.
 
-