akka.cluster

Class AutoDown

java.lang.Object

akka.cluster.AutoDownBase

akka.cluster.AutoDown

All Implemented Interfaces:

Actor, ActorLogging

public class AutoDown
extends AutoDownBase
implements ActorLogging

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

Nested Classes

Modifier and Type	Class and Description
static class	AutoDown.UnreachableTimeout
static class	AutoDown.UnreachableTimeout$

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
AutoDown(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)

Method Summary

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)

Methods inherited from class akka.cluster.AutoDownBase

context, downOrAddPending, leader, pendingUnreachable, receive, remove, scheduledUnreachable, scheduleUnreachable, self, 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.ActorLogging

log

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, 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)

sender

public static final ActorRef sender()

aroundReceive

protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                                    java.lang.Object msg)

aroundPreStart

protected static void aroundPreStart()

aroundPostStop

protected static void aroundPostStop()

aroundPreRestart

protected static void aroundPreRestart(java.lang.Throwable reason,
                                       scala.Option<java.lang.Object> message)

aroundPostRestart

protected static void aroundPostRestart(java.lang.Throwable reason)

supervisorStrategy

public static SupervisorStrategy supervisorStrategy()

preRestart

public static void preRestart(java.lang.Throwable reason,
                              scala.Option<java.lang.Object> message)
                       throws java.lang.Exception

Throws:

java.lang.Exception

postRestart

public static void postRestart(java.lang.Throwable reason)
                        throws java.lang.Exception

Throws:

java.lang.Exception

unhandled

public static void unhandled(java.lang.Object message)

skipMemberStatus

public static scala.collection.immutable.Set<MemberStatus> skipMemberStatus()

scheduledUnreachable

public static scala.collection.immutable.Map<UniqueAddress,Cancellable> scheduledUnreachable()

scheduledUnreachable_$eq

public static void scheduledUnreachable_$eq(scala.collection.immutable.Map<UniqueAddress,Cancellable> x$1)

pendingUnreachable

public static scala.collection.immutable.Set<UniqueAddress> pendingUnreachable()

pendingUnreachable_$eq

public static void pendingUnreachable_$eq(scala.collection.immutable.Set<UniqueAddress> x$1)

leader

public static boolean leader()

leader_$eq

public static void leader_$eq(boolean x$1)

receive

public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

unreachableMember

public static void unreachableMember(Member m)

scheduleUnreachable

public static void scheduleUnreachable(UniqueAddress node)

downOrAddPending

public static void downOrAddPending(UniqueAddress node)

remove

public static void remove(UniqueAddress node)

context

public static ActorContext context()

self

public static final ActorRef self()

akka$actor$Actor$_setter_$context_$eq

protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)

akka$actor$Actor$_setter_$self_$eq

protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)

akka$actor$ActorLogging$$_log

public static LoggingAdapter akka$actor$ActorLogging$$_log()

akka$actor$ActorLogging$$_log_$eq

public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)

log

public static LoggingAdapter log()

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.

Specified by:

preStart in interface Actor

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