Package akka.cluster
Class ClusterEvent
- java.lang.Object
-
- akka.cluster.ClusterEvent
-
public class ClusterEvent extends java.lang.Object
Domain events published to the event bus. Subscribe with:Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
ClusterEvent.ClusterDomainEvent
Marker interface for cluster domain events.static class
ClusterEvent.ClusterShuttingDown$
This event is published when the cluster node is shutting down, before the finalClusterEvent.MemberRemoved
events are published.static class
ClusterEvent.CurrentClusterState
static class
ClusterEvent.CurrentClusterState$
static class
ClusterEvent.CurrentInternalStats$
static interface
ClusterEvent.DataCenterReachabilityEvent
Deprecated.Use Akka Distributed Cluster instead.static class
ClusterEvent.InitialStateAsEvents$
When using this subscription mode the events corresponding to the current state will be sent to the subscriber to mimic what you would have seen if you were listening to the events when they occurred in the past.static class
ClusterEvent.InitialStateAsSnapshot$
When using this subscription mode a snapshot ofClusterEvent.CurrentClusterState
will be sent to the subscriber as the first message.static class
ClusterEvent.LeaderChanged
Leader of the cluster data center of this node changed.static class
ClusterEvent.LeaderChanged$
static class
ClusterEvent.MemberDowned
Member status changed toMemberStatus.Down
and will be removed when all members have seen theDown
status.static class
ClusterEvent.MemberDowned$
static interface
ClusterEvent.MemberEvent
Marker interface for membership events.static class
ClusterEvent.MemberExited
Member status changed toMemberStatus.Exiting
and will be removed when all members have seen theExiting
status.static class
ClusterEvent.MemberExited$
static class
ClusterEvent.MemberJoined
Member status changed to Joining.static class
ClusterEvent.MemberJoined$
static class
ClusterEvent.MemberLeft
Member status changed to Leaving.static class
ClusterEvent.MemberLeft$
static class
ClusterEvent.MemberPreparingForShutdown
static class
ClusterEvent.MemberPreparingForShutdown$
static class
ClusterEvent.MemberReadyForShutdown
static class
ClusterEvent.MemberReadyForShutdown$
static class
ClusterEvent.MemberRemoved
Member completely removed from the cluster.static class
ClusterEvent.MemberRemoved$
static class
ClusterEvent.MemberTombstonesChanged$
static class
ClusterEvent.MemberUp
Member status changed to Up.static class
ClusterEvent.MemberUp$
static class
ClusterEvent.MemberWeaklyUp
Member status changed to WeaklyUp.static class
ClusterEvent.MemberWeaklyUp$
static class
ClusterEvent.ReachabilityChanged$
static interface
ClusterEvent.ReachabilityEvent
Marker interface to facilitate subscription of bothClusterEvent.UnreachableMember
andClusterEvent.ReachableMember
.static class
ClusterEvent.ReachableDataCenter
Deprecated.Use Akka Distributed Cluster instead.static class
ClusterEvent.ReachableDataCenter$
static class
ClusterEvent.ReachableMember
A member is considered as reachable by the failure detector after having been unreachable.static class
ClusterEvent.ReachableMember$
static class
ClusterEvent.RoleLeaderChanged
First member (leader) of the members within a role set (in the same data center as this node, if data centers are used) changed.static class
ClusterEvent.RoleLeaderChanged$
static class
ClusterEvent.SeenChanged$
static class
ClusterEvent.SubscriptionInitialStateMode
static class
ClusterEvent.UnreachableDataCenter
Deprecated.Use Akka Distributed Cluster instead.static class
ClusterEvent.UnreachableDataCenter$
static class
ClusterEvent.UnreachableMember
A member is considered as unreachable by the failure detector.static class
ClusterEvent.UnreachableMember$
-
Constructor Summary
Constructors Constructor Description ClusterEvent()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static ClusterEvent.ClusterShuttingDown$
getClusterShuttingDownInstance()
Java API: get the singleton instance ofClusterShuttingDown
eventstatic ClusterEvent.InitialStateAsEvents$
initialStateAsEvents()
Java APIstatic ClusterEvent.InitialStateAsSnapshot$
initialStateAsSnapshot()
Java API
-
-
-
Method Detail
-
initialStateAsSnapshot
public static ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()
Java API
-
initialStateAsEvents
public static ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()
Java API
-
getClusterShuttingDownInstance
public static ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()
Java API: get the singleton instance ofClusterShuttingDown
event
-
-