Class ClusterReceptionist$
- java.lang.Object
-
- akka.cluster.typed.internal.receptionist.ClusterReceptionist$
-
- All Implemented Interfaces:
ReceptionistBehaviorProvider
public class ClusterReceptionist$ extends java.lang.Object implements ReceptionistBehaviorProvider
param: registry The last seen state from the replicator - only updated when we get an update from th replicator param: subscriptions Locally subscriptions, not replicated
-
-
Field Summary
Fields Modifier and Type Field Description static ClusterReceptionist$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description ClusterReceptionist$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Behavior<Receptionist.Command>
behavior()
Behavior<Receptionist.Command>
behavior(ClusterReceptionist.Setup setup, ShardedServiceRegistry registry, TypedMultiMap<AbstractServiceKey,ActorRef> subscriptions)
ORMultiMap<ServiceKey<?>,ClusterReceptionist.Entry>
EmptyORMultiMap()
-
-
-
Field Detail
-
MODULE$
public static final ClusterReceptionist$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
EmptyORMultiMap
public final ORMultiMap<ServiceKey<?>,ClusterReceptionist.Entry> EmptyORMultiMap()
-
behavior
public Behavior<Receptionist.Command> behavior()
- Specified by:
behavior
in interfaceReceptionistBehaviorProvider
-
behavior
public 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)
-
-