Package akka.cluster
Class AutoDown
- java.lang.Object
-
- akka.cluster.AutoDownBase
-
- akka.cluster.AutoDown
-
- All Implemented Interfaces:
Actor
,ActorLogging
public class AutoDown extends AutoDownBase implements ActorLogging
INTERNAL APIAn 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.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
AutoDown.UnreachableTimeout
static class
AutoDown.UnreachableTimeout$
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Cluster
cluster()
void
down(Address node)
void
postStop()
User overridable callback.void
preStart()
User overridable callback.static Props
props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
Scheduler
scheduler()
Address
selfAddress()
-
Methods inherited from class akka.cluster.AutoDownBase
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, downOrAddPending, leader, leader_$eq, pendingUnreachable, pendingUnreachable_$eq, receive, remove, scheduledUnreachable, scheduledUnreachable_$eq, scheduleUnreachable, self, skipMemberStatus, unreachableMember
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
-
-
-
Method Detail
-
props
public static Props props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
-
cluster
public Cluster cluster()
-
selfAddress
public Address selfAddress()
- Specified by:
selfAddress
in classAutoDownBase
-
scheduler
public Scheduler scheduler()
- Specified by:
scheduler
in classAutoDownBase
-
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.
-
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 interfaceActor
- Overrides:
postStop
in classAutoDownBase
-
down
public void down(Address node)
- Specified by:
down
in classAutoDownBase
-
-