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
-
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, ShardedServiceRegistry registry, TypedMultiMap<AbstractServiceKey,ActorRef> subscriptions)
static ORMultiMap<ServiceKey<?>,ClusterReceptionist.Entry>
EmptyORMultiMap()
-
-
-
Method Detail
-
EmptyORMultiMap
public static final ORMultiMap<ServiceKey<?>,ClusterReceptionist.Entry> EmptyORMultiMap()
-
behavior
public static Behavior<Receptionist.Command> behavior()
-
behavior
public static Behavior<Receptionist.Command> behavior(ClusterReceptionist.Setup setup, ShardedServiceRegistry registry, TypedMultiMap<AbstractServiceKey,ActorRef> subscriptions)
- Parameters:
registry
- The last seen state from the replicator - only updated when we get an update from th replicatorsubscriptions
- Locally subscriptions, not replicatedsetup
- (undocumented)- Returns:
- (undocumented)
-
-