Package org.apache.pekko.cluster.singleton

Class ClusterSingletonManager.Internal$.OldestChangedBuffer

  • All Implemented Interfaces:
    Actor
    Enclosing class:
    ClusterSingletonManager.Internal$
    public class ClusterSingletonManager.Internal$.OldestChangedBuffer
extends java.lang.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 Detail

      • OldestChangedBuffer

        public OldestChangedBuffer​(scala.Option<java.lang.String> role)

    • Method Detail

      • 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<java.lang.Object> changes()

      • changes_$eq

        public void changes_$eq​(scala.collection.immutable.Vector<java.lang.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)

      • add

        public void add​(Member m)

      • remove

        public void remove​(Member m)

      • sendFirstChange

        public void sendFirstChange()

      • receive

        public scala.PartialFunction<java.lang.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<java.lang.Object,​scala.runtime.BoxedUnit> deliverNext()

      • deliverChanges

        public void deliverChanges()

      • unhandled

        public void unhandled​(java.lang.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