Package org.apache.pekko.cluster.client

Class ClusterClientReceptionist

java.lang.Object
org.apache.pekko.cluster.client.ClusterClientReceptionist
All Implemented Interfaces:
Extension
public final class ClusterClientReceptionist extends Object implements Extension
Deprecated.
Use Apache Pekko gRPC instead, see https://pekko.apache.org/docs/pekko/current/cluster-client.html#migration-to-pekko-grpc. Since Akka 2.6.0.
Extension that starts ClusterReceptionist and accompanying pekko.cluster.pubsub.DistributedPubSubMediator with settings defined in config section pekko.cluster.client.receptionist. The pekko.cluster.pubsub.DistributedPubSubMediator is started by the pekko.cluster.pubsub.DistributedPubSub extension.

  • Constructor Details

    • ClusterClientReceptionist

      public ClusterClientReceptionist(ExtendedActorSystem system)
      Deprecated.

  • Method Details

    • get

      public static ClusterClientReceptionist get(ActorSystem system)
      Deprecated.

    • get

      public static ClusterClientReceptionist get(ClassicActorSystemProvider system)
      Deprecated.

    • lookup

      public static ClusterClientReceptionist$ lookup()
      Deprecated.

    • createExtension

      public static ClusterClientReceptionist createExtension(ExtendedActorSystem system)
      Deprecated.

    • apply

      public static T apply(ActorSystem system)
      Deprecated.

    • apply

      public static T apply(ClassicActorSystemProvider system)
      Deprecated.

    • hashCode

      public static final int hashCode()
      Deprecated.

    • equals

      public static final boolean equals(Object other)
      Deprecated.

    • isTerminated

      public boolean isTerminated()
      Deprecated.
      Returns true if this member is not tagged with the role configured for the receptionist.

    • registerService

      public void registerService(ActorRef actor)
      Deprecated.
      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".

    • unregisterService

      public void unregisterService(ActorRef actor)
      Deprecated.
      A registered actor will be automatically unregistered when terminated, but it can also be explicitly unregistered before termination.

    • registerSubscriber

      public void registerSubscriber(String topic, ActorRef actor)
      Deprecated.
      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.

    • unregisterSubscriber

      public void unregisterSubscriber(String topic, ActorRef actor)
      Deprecated.
      A registered subscriber will be automatically unregistered when terminated, but it can also be explicitly unregistered before termination.

    • underlying

      public ActorRef underlying()
      Deprecated.
      Returns the underlying receptionist actor, particularly so that its events can be observed via subscribe/unsubscribe.