Package akka.cluster

Class AutoDown

  • All Implemented Interfaces:
    Actor, ActorLogging

    public class AutoDown
    extends AutoDownBase
    implements ActorLogging

    An unreachable member will be downed by this actor if it remains unreachable for the specified duration and this actor is running on the leader node in the cluster.

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

    • Constructor Detail

      • AutoDown

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

      • props

        public static Props props​(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
      • sender

        public static final ActorRef sender()
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
      • aroundPreStart

        protected static void aroundPreStart()
      • aroundPostStop

        protected static void aroundPostStop()
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      scala.Option<java.lang.Object> message)
                               throws java.lang.Exception
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
                                throws java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
      • skipMemberStatus

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

        public static scala.collection.immutable.Map<UniqueAddress,​Cancellable> scheduledUnreachable()
      • scheduledUnreachable_$eq

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

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

        public static void pendingUnreachable_$eq​(scala.collection.immutable.Set<UniqueAddress> x$1)
      • leader

        public static boolean leader()
      • leader_$eq

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

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
      • unreachableMember

        public static void unreachableMember​(Member m)
      • scheduleUnreachable

        public static void scheduleUnreachable​(UniqueAddress node)
      • downOrAddPending

        public static void downOrAddPending​(UniqueAddress node)
      • self

        public static final ActorRef self()
      • akka$actor$Actor$_setter_$context_$eq

        protected static void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
      • akka$actor$Actor$_setter_$self_$eq

        protected static final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
      • cluster

        public Cluster cluster()
      • 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
        postStop in class AutoDownBase