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.

Nested Class Summary

static class	AutoDown.UnreachableTimeout
static class	AutoDown.UnreachableTimeout$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$

Constructor Summary

AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)

Method Summary

Cluster	cluster()
void	down(Address node)
void	postStop() User overridable callback.
void	preStart() User overridable callback.
static Props	props(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
Scheduler	scheduler()
Address	selfAddress()

Methods inherited from class akka.cluster.AutoDownBase

downOrAddPending, leader, pendingUnreachable, receive, remove, scheduledUnreachable, scheduleUnreachable, skipMemberStatus, unreachableMember

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

Constructor Detail

AutoDown

public AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)

Method Detail

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