akka.cluster
Class AutoDownBase

java.lang.Object
  extended by 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.


Nested Class Summary
 
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$
 
Constructor Summary
AutoDownBase(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
           
 
Method Summary
abstract  void down(Address node)
           
 void downOrAddPending(UniqueAddress node)
           
 boolean leader()
           
 scala.collection.immutable.Set<UniqueAddress> pendingUnreachable()
           
 void postStop()
          User overridable callback.
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
          This defines the initial actor behavior, it must return a partial function with the actor logic.
 void remove(UniqueAddress node)
           
 scala.collection.immutable.Map<UniqueAddress,Cancellable> scheduledUnreachable()
           
abstract  Scheduler scheduler()
           
 void scheduleUnreachable(UniqueAddress node)
           
abstract  Address selfAddress()
           
 scala.collection.immutable.Set<MemberStatus> skipMemberStatus()
           
 void unreachableMember(Member m)
           
 
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
 

Constructor Detail

AutoDownBase

public AutoDownBase(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
Method Detail

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)