public class AutoDown extends AutoDownBase
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.
Modifier and Type | Class and Description |
---|---|
static class |
AutoDown.UnreachableTimeout |
static class |
AutoDown.UnreachableTimeout$ |
Constructor and Description |
---|
AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter) |
Modifier and Type | Method and Description |
---|---|
Cluster |
cluster() |
void |
down(akka.actor.Address node) |
void |
postStop() |
void |
preStart() |
static akka.actor.Props |
props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter) |
akka.actor.Scheduler |
scheduler() |
akka.actor.Address |
selfAddress() |
downOrAddPending, leader, pendingUnreachable, receive, remove, scheduledUnreachable, scheduleUnreachable, skipMemberStatus, unreachableMember
public AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
public static akka.actor.Props props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
public Cluster cluster()
public akka.actor.Address selfAddress()
selfAddress
in class AutoDownBase
public akka.actor.Scheduler scheduler()
scheduler
in class AutoDownBase
public void preStart()
public void postStop()
postStop
in interface akka.actor.Actor
postStop
in class AutoDownBase
public void down(akka.actor.Address node)
down
in class AutoDownBase