final class ClusterClientReceptionist extends Extension

Extension that starts ClusterReceptionist and accompanying akka.cluster.pubsub.DistributedPubSubMediator with settings defined in config section akka.cluster.client.receptionist. The akka.cluster.pubsub.DistributedPubSubMediator is started by the akka.cluster.pubsub.DistributedPubSub extension.

Source
ClusterClient.scala
Linear Supertypes
Extension, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ClusterClientReceptionist
  2. Extension
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ClusterClientReceptionist(system: ExtendedActorSystem)

Value Members

  1. def isTerminated: Boolean

    Returns true if this member is not tagged with the role configured for the receptionist.

  2. def registerService(actor: ActorRef): Unit

    Register an actor that should be reachable for the clients.

    Register an actor that should be reachable for the clients. The clients can send messages to this actor with Send or SendToAll using the path elements of the ActorRef, e.g. "/user/myservice".

  3. def registerSubscriber(topic: String, actor: ActorRef): Unit

    Register an actor that should be reachable for the clients to a named topic.

    Register an actor that should be reachable for the clients to a named topic. Several actors can be registered to the same topic name, and all will receive published messages. The client can publish messages to this topic with Publish.

  4. def underlying: ActorRef

    Returns the underlying receptionist actor, particularly so that its events can be observed via subscribe/unsubscribe.

  5. def unregisterService(actor: ActorRef): Unit

    A registered actor will be automatically unregistered when terminated, but it can also be explicitly unregistered before termination.

  6. def unregisterSubscriber(topic: String, actor: ActorRef): Unit

    A registered subscriber will be automatically unregistered when terminated, but it can also be explicitly unregistered before termination.