Package akka.cluster.typed.internal
Class AdapterClusterImpl
- java.lang.Object
-
- akka.cluster.typed.Cluster
-
- akka.cluster.typed.internal.AdapterClusterImpl
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
AdapterClusterImpl.SeenState
-
Constructor Summary
Constructors Constructor Description AdapterClusterImpl(ActorSystem<?> system)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isTerminated()
Returns true if this cluster instance has be shutdown.ActorRef<ClusterCommand>
manager()
Member
selfMember()
ClusterEvent.CurrentClusterState
state()
Current snapshot state of the cluster.ActorRef<ClusterStateSubscription>
subscriptions()
-
-
-
Constructor Detail
-
AdapterClusterImpl
public AdapterClusterImpl(ActorSystem<?> system)
-
-
Method Detail
-
selfMember
public Member selfMember()
- Specified by:
selfMember
in classCluster
-
isTerminated
public boolean isTerminated()
Description copied from class:Cluster
Returns true if this cluster instance has be shutdown.- Specified by:
isTerminated
in classCluster
-
state
public ClusterEvent.CurrentClusterState state()
Description copied from class:Cluster
Current snapshot state of the cluster.
-
subscriptions
public ActorRef<ClusterStateSubscription> subscriptions()
- Specified by:
subscriptions
in classCluster
- Returns:
- an actor that allows for subscribing to messages when the cluster state changes
-
manager
public ActorRef<ClusterCommand> manager()
-
-