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.
Modifier and Type | Class and Description |
---|---|
static class |
AutoDown.UnreachableTimeout |
static class |
AutoDown.UnreachableTimeout$ |
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter) |
Modifier and Type | Method and Description |
---|---|
protected static void |
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1) |
protected static void |
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1) |
static void |
akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1) |
static LoggingAdapter |
akka$actor$ActorLogging$$_log() |
protected static void |
aroundPostRestart(java.lang.Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object msg) |
Cluster |
cluster() |
static ActorContext |
context() |
void |
down(Address node) |
static void |
downOrAddPending(UniqueAddress node) |
static void |
leader_$eq(boolean x$1) |
static boolean |
leader() |
static LoggingAdapter |
log() |
static void |
pendingUnreachable_$eq(scala.collection.immutable.Set<UniqueAddress> x$1) |
static scala.collection.immutable.Set<UniqueAddress> |
pendingUnreachable() |
static void |
postRestart(java.lang.Throwable reason) |
void |
postStop()
User overridable callback.
|
static void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
void |
preStart()
User overridable callback.
|
static Props |
props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter) |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
static void |
remove(UniqueAddress node) |
static void |
scheduledUnreachable_$eq(scala.collection.immutable.Map<UniqueAddress,Cancellable> x$1) |
static scala.collection.immutable.Map<UniqueAddress,Cancellable> |
scheduledUnreachable() |
Scheduler |
scheduler() |
static void |
scheduleUnreachable(UniqueAddress node) |
static ActorRef |
self() |
Address |
selfAddress() |
static ActorRef |
sender() |
static scala.collection.immutable.Set<MemberStatus> |
skipMemberStatus() |
static SupervisorStrategy |
supervisorStrategy() |
static void |
unhandled(java.lang.Object message) |
static void |
unreachableMember(Member m) |
context, downOrAddPending, leader, pendingUnreachable, receive, remove, scheduledUnreachable, scheduleUnreachable, self, skipMemberStatus, unreachableMember
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
log
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled
public AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
public static Props props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
public static final ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void aroundPostRestart(java.lang.Throwable reason)
public static SupervisorStrategy supervisorStrategy()
public static void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message) throws java.lang.Exception
java.lang.Exception
public static void postRestart(java.lang.Throwable reason) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
public static scala.collection.immutable.Set<MemberStatus> skipMemberStatus()
public static scala.collection.immutable.Map<UniqueAddress,Cancellable> scheduledUnreachable()
public static void scheduledUnreachable_$eq(scala.collection.immutable.Map<UniqueAddress,Cancellable> x$1)
public static scala.collection.immutable.Set<UniqueAddress> pendingUnreachable()
public static void pendingUnreachable_$eq(scala.collection.immutable.Set<UniqueAddress> x$1)
public static boolean leader()
public static void leader_$eq(boolean x$1)
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
public static void unreachableMember(Member m)
public static void scheduleUnreachable(UniqueAddress node)
public static void downOrAddPending(UniqueAddress node)
public static void remove(UniqueAddress node)
public static ActorContext context()
public static final ActorRef self()
protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public static LoggingAdapter akka$actor$ActorLogging$$_log()
public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
public static LoggingAdapter log()
public Cluster cluster()
public Address selfAddress()
selfAddress
in class AutoDownBase
public Scheduler scheduler()
scheduler
in class AutoDownBase
public void preStart()
Actor
public void postStop()
Actor
postStop
in interface Actor
postStop
in class AutoDownBase
public void down(Address node)
down
in class AutoDownBase