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 classAutoDown.UnreachableTimeoutstatic classAutoDown.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 Clustercluster()voiddown(Address node)voidpostStop()User overridable callback.voidpreStart()User overridable callback.static Propsprops(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)Schedulerscheduler()AddressselfAddress()-
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:
selfAddressin classAutoDownBase
-
scheduler
public Scheduler scheduler()
- Specified by:
schedulerin classAutoDownBase
-
preStart
public void preStart()
Description copied from interface:ActorUser 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:ActorUser overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.- Specified by:
postStopin interfaceActor- Overrides:
postStopin classAutoDownBase
-
down
public void down(Address node)
- Specified by:
downin classAutoDownBase
-
-