Package akka.cluster.typed.internal.receptionist

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

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterReceptionist

public ClusterReceptionist()

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 replicator

subscriptions - Locally subscriptions, not replicated

setup - (undocumented)

Returns:

(undocumented)