Package org.apache.pekko.cluster.singleton

Class ClusterSingletonManager.Internal$.OldestChangedBuffer

java.lang.Object
org.apache.pekko.cluster.singleton.ClusterSingletonManager.Internal$.OldestChangedBuffer
All Implemented Interfaces:
Actor
Enclosing class:
ClusterSingletonManager.Internal$
public class ClusterSingletonManager.Internal$.OldestChangedBuffer extends Object implements Actor
Notifications of member events that track oldest member are tunneled via this actor (child of ClusterSingletonManager) to be able to deliver one change at a time. Avoiding simultaneous changes simplifies the process in ClusterSingletonManager. ClusterSingletonManager requests next event with GetNext when it is ready for it. Only one outstanding GetNext request is allowed. Incoming events are buffered and delivered upon GetNext request.

  • Constructor Details

    • OldestChangedBuffer

      public OldestChangedBuffer(scala.Option<String> role)

  • Method Details

    • context

      public ActorContext context()
      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()
      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)
      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)
      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

    • cluster

      public Cluster cluster()

    • ageOrdering

      public scala.math.Ordering<Member> ageOrdering()

    • membersByAge

      public scala.collection.immutable.SortedSet<Member> membersByAge()

    • membersByAge_$eq

      public void membersByAge_$eq(scala.collection.immutable.SortedSet<Member> x$1)

    • changes

      public scala.collection.immutable.Vector<Object> changes()

    • changes_$eq

      public void changes_$eq(scala.collection.immutable.Vector<Object> x$1)

    • preStart

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

      Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
      Specified by:
      preStart in interface Actor

    • postStop

      public void postStop()
      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

    • matchingRole

      public boolean matchingRole(Member member)

    • trackChange

      public void trackChange(scala.Function0<scala.runtime.BoxedUnit> block)

    • handleInitial

      public void handleInitial(ClusterEvent.CurrentClusterState state)

    • add

      public void add(Member m)

    • remove

      public void remove(Member m)

    • sendFirstChange

      public void sendFirstChange()

    • receive

      public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
      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

    • deliverNext

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

    • deliverChanges

      public void deliverChanges()

    • unhandled

      public void unhandled(Object msg)
      Description copied from interface: Actor
      User overridable callback.

      Is called when a message isn't handled by the current behavior of the actor by default it fails with either a pekko.actor.DeathPactException (in case of an unhandled pekko.actor.Terminated message) or publishes an pekko.actor.UnhandledMessage to the actor's system's pekko.event.EventStream
      Specified by:
      unhandled in interface Actor