Package akka.cluster

Class AutoDownBase

  • All Implemented Interfaces:
    Direct Known Subclasses:

    public abstract class AutoDownBase
    extends java.lang.Object
    implements Actor

    The implementation is split into two classes AutoDown and AutoDownBase to be able to unit test the logic without running cluster.

    • Constructor Detail

      • AutoDownBase

        public AutoDownBase​(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
    • Method Detail

      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$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:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        x$1 - (undocumented)
      • 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!

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

        Specified by:
        context in interface Actor
      • down

        public abstract void down​(Address node)
      • downOrAddPending

        public void downOrAddPending​(UniqueAddress node)
      • leader

        public boolean leader()
      • leader_$eq

        public void leader_$eq​(boolean x$1)
      • pendingUnreachable

        public scala.collection.immutable.Set<UniqueAddress> pendingUnreachable()
      • pendingUnreachable_$eq

        public void pendingUnreachable_$eq​(scala.collection.immutable.Set<UniqueAddress> x$1)
      • 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
      • 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
      • scheduleUnreachable

        public void scheduleUnreachable​(UniqueAddress node)
      • scheduledUnreachable_$eq

        public void scheduledUnreachable_$eq​(scala.collection.immutable.Map<UniqueAddress,​Cancellable> x$1)
      • scheduler

        public abstract Scheduler scheduler()
      • 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
      • selfAddress

        public abstract Address selfAddress()
      • skipMemberStatus

        public scala.collection.immutable.Set<MemberStatus> skipMemberStatus()
      • unreachableMember

        public void unreachableMember​(Member m)