Package org.apache.pekko.cluster.client

Class ClusterClient

java.lang.Object
org.apache.pekko.cluster.client.ClusterClient
All Implemented Interfaces:
Actor, ActorLogging
public final class ClusterClient extends Object implements Actor, ActorLogging
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.
This actor is intended to be used on an external node that is not member of the cluster. It acts like a gateway for sending messages to actors somewhere in the cluster. From the initial contact points it will establish a connection to a ClusterReceptionist somewhere in the cluster. It will monitor the connection to the receptionist and establish a new connection if the link goes down. When looking for a new receptionist it uses fresh contact points retrieved from previous establishment, or periodically refreshed contacts, i.e. not necessarily the initial contact points.

You can send messages via the ClusterClient to any actor in the cluster that is registered in the ClusterReceptionist. Messages are wrapped in ClusterClient.Send, ClusterClient.SendToAll or ClusterClient.Publish.

1. ClusterClient.Send - The message will be delivered to one recipient with a matching path, if any such exists. If several entries match the path the message will be delivered to one random destination. The sender of the message can specify that local affinity is preferred, i.e. the message is sent to an actor in the same local actor system as the used receptionist actor, if any such exists, otherwise random to any other matching entry.

2. ClusterClient.SendToAll - The message will be delivered to all recipients with a matching path.

3. ClusterClient.Publish - The message will be delivered to all recipients Actors that have been registered as subscribers to to the named topic.

Use the factory method props(org.apache.pekko.cluster.client.ClusterClientSettings)) to create the pekko.actor.Props for the actor.

If the receptionist is not currently available, the client will buffer the messages and then deliver them when the connection to the receptionist has been established. The size of the buffer is configurable and it can be disabled by using a buffer size of 0. When the buffer is full old messages will be dropped when new messages are sent via the client.

Note that this is a best effort implementation: messages can always be lost due to the distributed nature of the actors involved.

  • Constructor Details

  • Method Details

    • props

      public static Props props(ClusterClientSettings settings)
      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.
      Scala API: Factory method for ClusterClient pekko.actor.Props.

    • context

      public ActorContext context()
      Deprecated.
      Description copied from interface: Actor
      Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

      WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

      pekko.actor.ActorContext is the Scala API. getContext returns a pekko.actor.AbstractActor.ActorContext, which is the Java API of the actor context.

      Specified by:
      context in interface Actor

    • self

      public final ActorRef self()
      Deprecated.
      Description copied from interface: Actor
      The 'self' field holds the ActorRef for this actor.

      Can be used to send messages to itself: 
       self ! message
      Specified by:
      self in interface Actor

    • org$apache$pekko$actor$Actor$_setter_$context_$eq

      protected void org$apache$pekko$actor$Actor$_setter_$context_$eq(ActorContext x$1)
      Deprecated.
      Description copied from interface: Actor
      Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

      WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

      pekko.actor.ActorContext is the Scala API. getContext returns a pekko.actor.AbstractActor.ActorContext, which is the Java API of the actor context.

      Specified by:
      org$apache$pekko$actor$Actor$_setter_$context_$eq in interface Actor

    • org$apache$pekko$actor$Actor$_setter_$self_$eq

      protected final void org$apache$pekko$actor$Actor$_setter_$self_$eq(ActorRef x$1)
      Deprecated.
      Description copied from interface: Actor
      The 'self' field holds the ActorRef for this actor.

      Can be used to send messages to itself: 
       self ! message
      Specified by:
      org$apache$pekko$actor$Actor$_setter_$self_$eq in interface Actor

    • failureDetector

      public DeadlineFailureDetector failureDetector()
      Deprecated.

    • contactPaths

      public scala.collection.immutable.HashSet<ActorPath> contactPaths()
      Deprecated.

    • contactPaths_$eq

      public void contactPaths_$eq(scala.collection.immutable.HashSet<ActorPath> x$1)
      Deprecated.

    • initialContactsSel

      public scala.collection.immutable.HashSet<ActorSelection> initialContactsSel()
      Deprecated.

    • contacts

      public scala.collection.immutable.HashSet<ActorSelection> contacts()
      Deprecated.

    • contacts_$eq

      public void contacts_$eq(scala.collection.immutable.HashSet<ActorSelection> x$1)
      Deprecated.

    • contactPathsPublished

      public scala.collection.immutable.HashSet<ActorPath> contactPathsPublished()
      Deprecated.

    • contactPathsPublished_$eq

      public void contactPathsPublished_$eq(scala.collection.immutable.HashSet<ActorPath> x$1)
      Deprecated.

    • subscribers

      public scala.collection.immutable.Vector<ActorRef> subscribers()
      Deprecated.

    • subscribers_$eq

      public void subscribers_$eq(scala.collection.immutable.Vector<ActorRef> x$1)
      Deprecated.

    • heartbeatTask

      public Cancellable heartbeatTask()
      Deprecated.

    • refreshContactsTask

      public scala.Option<Cancellable> refreshContactsTask()
      Deprecated.

    • refreshContactsTask_$eq

      public void refreshContactsTask_$eq(scala.Option<Cancellable> x$1)
      Deprecated.

    • buffer

      public MessageBuffer buffer()
      Deprecated.

    • buffer_$eq

      public void buffer_$eq(MessageBuffer x$1)
      Deprecated.

    • scheduleRefreshContactsTick

      public void scheduleRefreshContactsTick(scala.concurrent.duration.FiniteDuration interval)
      Deprecated.

    • postStop

      public void postStop()
      Deprecated.
      Description copied from interface: Actor
      User overridable callback.

      Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
      Specified by:
      postStop in interface Actor

    • receive

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
      Deprecated.
      Description copied from interface: Actor
      Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
      Specified by:
      receive in interface Actor

    • establishing

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> establishing()
      Deprecated.

    • active

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> active(ActorRef receptionist)
      Deprecated.

    • contactPointMessages

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> contactPointMessages()
      Deprecated.

    • sendGetContacts

      public void sendGetContacts()
      Deprecated.

    • buffer

      public void buffer(Object msg)
      Deprecated.

    • sendBuffered

      public void sendBuffered(ActorRef receptionist)
      Deprecated.

    • publishContactPoints

      public void publishContactPoints()
      Deprecated.

    • reestablish

      public void reestablish()
      Deprecated.