Package akka.cluster

Class ClusterRemoteWatcher

java.lang.Object

akka.remote.RemoteWatcher

akka.cluster.ClusterRemoteWatcher

All Implemented Interfaces:

Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>

public class ClusterRemoteWatcher
extends RemoteWatcher

When a cluster node is added this class takes over the responsibility for watchees on that node already handled by super RemoteWatcher.

Nested Class Summary

Nested classes/interfaces inherited from class akka.remote.RemoteWatcher

RemoteWatcher.ArteryHeartbeat$, RemoteWatcher.ArteryHeartbeatRsp, RemoteWatcher.ArteryHeartbeatRsp$, RemoteWatcher.ExpectedFirstHeartbeat, RemoteWatcher.ExpectedFirstHeartbeat$, RemoteWatcher.Heartbeat$, RemoteWatcher.HeartbeatRsp, RemoteWatcher.HeartbeatRsp$, RemoteWatcher.HeartbeatTick$, RemoteWatcher.ReapUnreachableTick$, RemoteWatcher.Stats, RemoteWatcher.Stats$, RemoteWatcher.UnwatchRemote, RemoteWatcher.UnwatchRemote$, RemoteWatcher.WatchRemote, RemoteWatcher.WatchRemote$

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor	Description
ClusterRemoteWatcher(FailureDetectorRegistry<Address> failureDetector, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration unreachableReaperInterval, scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)

Method Summary

Modifier and Type	Method	Description
Cluster	cluster()
scala.collection.immutable.Set<Address>	clusterNodes()
void	clusterNodes_$eq(scala.collection.immutable.Set<Address> x$1)
void	delayedQuarantine(Member m, MemberStatus previousStatus)
void	memberRemoved(Member m, MemberStatus previousStatus)
void	memberUp(Member m)
void	postStop()	User overridable callback.
void	preStart()	User overridable callback.
static Props	props(FailureDetectorRegistry<Address> failureDetector, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration unreachableReaperInterval, scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)
void	quarantineOldIncarnation(Member newIncarnation)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()	Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveClusterEvent()
void	takeOverResponsibility(Address address)	When a cluster node is added this class takes over the responsibility for watchees on that node already handled by super RemoteWatcher.
void	watchNode(InternalActorRef watchee)

Methods inherited from class akka.remote.RemoteWatcher

addressUids, addressUids_$eq, addWatch, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, artery, context, failureDetectorReaperTask, heartBeatMsg, heartbeatTask, publishAddressTerminated, quarantine, reapUnreachable, receiveHeartbeat, receiveHeartbeatRsp, remoteProvider, removeWatch, removeWatchee, reWatch, scheduler, self, selfHeartbeatRspMsg, sendHeartbeat, terminated, triggerFirstHeartbeat, unreachable, unreachable_$eq, unwatchNode, watcheeByNodes, watching, watchingNodes

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, postRestart, preRestart, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging

_log_$eq, log

Constructor Detail

ClusterRemoteWatcher

public ClusterRemoteWatcher(FailureDetectorRegistry<Address> failureDetector,
                            scala.concurrent.duration.FiniteDuration heartbeatInterval,
                            scala.concurrent.duration.FiniteDuration unreachableReaperInterval,
                            scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)

Method Detail

props

public static Props props(FailureDetectorRegistry<Address> failureDetector,
                          scala.concurrent.duration.FiniteDuration heartbeatInterval,
                          scala.concurrent.duration.FiniteDuration unreachableReaperInterval,
                          scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)

cluster

public Cluster cluster()

clusterNodes

public scala.collection.immutable.Set<Address> clusterNodes()

clusterNodes_$eq

public void clusterNodes_$eq(scala.collection.immutable.Set<Address> x$1)

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 RemoteWatcher

receive

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

Description copied from interface: Actor

Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:

receive in interface Actor

Overrides:

receive in class RemoteWatcher

Returns:

(undocumented)

receiveClusterEvent

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

memberUp

public void memberUp(Member m)

memberRemoved

public void memberRemoved(Member m,
                          MemberStatus previousStatus)

quarantineOldIncarnation

public void quarantineOldIncarnation(Member newIncarnation)

delayedQuarantine

public void delayedQuarantine(Member m,
                              MemberStatus previousStatus)

watchNode

public void watchNode(InternalActorRef watchee)

Overrides:

watchNode in class RemoteWatcher

takeOverResponsibility

public void takeOverResponsibility(Address address)

When a cluster node is added this class takes over the responsibility for watchees on that node already handled by super RemoteWatcher.

Parameters:

address - (undocumented)