public class ClusterRemoteWatcher
extends akka.remote.RemoteWatcher
Specialization of RemoteWatcher
that keeps
track of cluster member nodes and is responsible for watchees on cluster nodes.
AddressTerminated
is published when node is removed from cluster.
RemoteWatcher
handles non-cluster nodes. ClusterRemoteWatcher
will take
over responsibility from RemoteWatcher
if a watch is added before a node is member
of the cluster and then later becomes cluster member.
akka.remote.RemoteWatcher.ExpectedFirstHeartbeat, akka.remote.RemoteWatcher.ExpectedFirstHeartbeat$, akka.remote.RemoteWatcher.Heartbeat$, akka.remote.RemoteWatcher.HeartbeatRsp, akka.remote.RemoteWatcher.HeartbeatRsp$, akka.remote.RemoteWatcher.HeartbeatTick$, akka.remote.RemoteWatcher.ReapUnreachableTick$, akka.remote.RemoteWatcher.Stats, akka.remote.RemoteWatcher.Stats$, akka.remote.RemoteWatcher.UnwatchRemote, akka.remote.RemoteWatcher.UnwatchRemote$, akka.remote.RemoteWatcher.WatchRemote, akka.remote.RemoteWatcher.WatchRemote$
Constructor and Description |
---|
ClusterRemoteWatcher(akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector,
scala.concurrent.duration.FiniteDuration heartbeatInterval,
scala.concurrent.duration.FiniteDuration unreachableReaperInterval,
scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter) |
Modifier and Type | Method and Description |
---|---|
Cluster |
cluster() |
scala.collection.immutable.Set<akka.actor.Address> |
clusterNodes() |
void |
memberRemoved(Member m,
MemberStatus previousStatus) |
void |
memberUp(Member m) |
void |
postStop() |
void |
preStart() |
static akka.actor.Props |
props(akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector,
scala.concurrent.duration.FiniteDuration heartbeatInterval,
scala.concurrent.duration.FiniteDuration unreachableReaperInterval,
scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)
Factory method for
ClusterRemoteWatcher Props . |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveClusterEvent() |
void |
takeOverResponsibility(akka.actor.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(akka.actor.InternalActorRef watchee) |
addressUids_$eq, addressUids, addWatch, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, failureDetectorReaperTask, heartbeatTask, log, postRestart, preRestart, publishAddressTerminated, quarantine, reapUnreachable, receiveHeartbeat, receiveHeartbeatRsp, remoteProvider, removeWatch, removeWatchee, reWatch, scheduler, self, selfHeartbeatRspMsg, sender, sendHeartbeat, supervisorStrategy, terminated, triggerFirstHeartbeat, unhandled, unreachable_$eq, unreachable, unwatchNode, watcheeByNodes, watching, watchingNodes
public ClusterRemoteWatcher(akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration unreachableReaperInterval, scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)
public static akka.actor.Props props(akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration unreachableReaperInterval, scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)
ClusterRemoteWatcher
Props
.failureDetector
- (undocumented)heartbeatInterval
- (undocumented)unreachableReaperInterval
- (undocumented)heartbeatExpectedResponseAfter
- (undocumented)public Cluster cluster()
public scala.collection.immutable.Set<akka.actor.Address> clusterNodes()
public void preStart()
preStart
in interface akka.actor.Actor
preStart
in class akka.remote.RemoteWatcher
public void postStop()
postStop
in interface akka.actor.Actor
postStop
in class akka.remote.RemoteWatcher
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
receive
in class akka.remote.RemoteWatcher
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveClusterEvent()
public void memberUp(Member m)
public void memberRemoved(Member m, MemberStatus previousStatus)
public void watchNode(akka.actor.InternalActorRef watchee)
watchNode
in class akka.remote.RemoteWatcher
public void takeOverResponsibility(akka.actor.Address address)
address
- (undocumented)