Package org.apache.storm.nimbus
Class LeaderListenerCallback
java.lang.Object
org.apache.storm.nimbus.LeaderListenerCallback
A callback function when nimbus gains leadership.
-
Constructor Summary
ConstructorsConstructorDescriptionLeaderListenerCallback
(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 Summary
Modifier and TypeMethodDescriptionvoid
leaderCallBack
(Object lock) Invoke when gains leadership.void
Invoke when lost leadership.
-
Constructor Details
-
LeaderListenerCallback
public 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
- configzk
- zookeeper CuratorFramework clientblobStore
- BlobStoreleaderElector
- Leader electortc
- TopoCacheclusterState
- IStormClusterStateacls
- zookeeper acls
-
-
Method Details
-
leaderCallBack
Invoke when gains leadership. -
notLeaderCallback
public void notLeaderCallback()Invoke when lost leadership.
-