akka.cluster
Class AutoDownBase
java.lang.Object
akka.cluster.AutoDownBase
- All Implemented Interfaces:
- Actor
- Direct Known Subclasses:
- AutoDown
public abstract class AutoDownBase
- extends java.lang.Object
- implements Actor
INTERNAL API
The implementation is split into two classes AutoDown and AutoDownBase to be
able to unit test the logic without running cluster.
Constructor Summary |
AutoDownBase(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, preStart, self, sender, supervisorStrategy, unhandled |
AutoDownBase
public AutoDownBase(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
selfAddress
public abstract Address selfAddress()
down
public abstract void down(Address node)
scheduler
public abstract Scheduler scheduler()
skipMemberStatus
public scala.collection.immutable.Set<MemberStatus> skipMemberStatus()
scheduledUnreachable
public scala.collection.immutable.Map<UniqueAddress,Cancellable> scheduledUnreachable()
pendingUnreachable
public scala.collection.immutable.Set<UniqueAddress> pendingUnreachable()
leader
public boolean leader()
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
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
- Returns:
- (undocumented)
unreachableMember
public void unreachableMember(Member m)
scheduleUnreachable
public void scheduleUnreachable(UniqueAddress node)
downOrAddPending
public void downOrAddPending(UniqueAddress node)
remove
public void remove(UniqueAddress node)