akka.cluster
Class AutoDown
java.lang.Object
akka.cluster.AutoDownBase
akka.cluster.AutoDown
- All Implemented Interfaces:
- Actor
public class AutoDown
- extends AutoDownBase
INTERNAL API
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 Summary |
AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
|
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, context, postRestart, preRestart, self, sender, supervisorStrategy, unhandled |
AutoDown
public AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
props
public static Props props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
cluster
public Cluster cluster()
selfAddress
public Address selfAddress()
- Specified by:
selfAddress
in class AutoDownBase
scheduler
public Scheduler scheduler()
- Specified by:
scheduler
in class AutoDownBase
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 interface Actor
- Overrides:
postStop
in class AutoDownBase
down
public void down(Address node)
- Specified by:
down
in class AutoDownBase