Class ClusterReceptionist
- java.lang.Object
-
- akka.cluster.typed.internal.receptionist.ClusterReceptionist
-
public final class ClusterReceptionist extends java.lang.Object
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ClusterReceptionist.Entry
static class
ClusterReceptionist.Entry$
static interface
ClusterReceptionist.InternalCommand
static class
ClusterReceptionist.Setup
static class
ClusterReceptionist.State
param: registry The last seen state from the replicator - only updated when we get an update from th replicator param: servicesPerActor needed since an actor can implement several services param: tombstones Local actors that were stopped and should not be re-added to the available set of actors for a key.static class
ClusterReceptionist.State$
-
Constructor Summary
Constructors Constructor Description ClusterReceptionist()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Behavior<Receptionist.Command>
behavior()
static Behavior<Receptionist.Command>
behavior(ClusterReceptionist.Setup setup, ClusterReceptionist.State state)
static ORMultiMap<ServiceKey<?>,ClusterReceptionist.Entry>
EmptyORMultiMap()
static java.lang.String
name()
-
-
-
Method Detail
-
EmptyORMultiMap
public static final ORMultiMap<ServiceKey<?>,ClusterReceptionist.Entry> EmptyORMultiMap()
-
name
public static java.lang.String name()
-
behavior
public static Behavior<Receptionist.Command> behavior()
-
behavior
public static Behavior<Receptionist.Command> behavior(ClusterReceptionist.Setup setup, ClusterReceptionist.State state)
-
-