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
All Methods Static Methods Instance Methods Concrete Methods 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 interfaceActor
- Overrides:
postStop
in classRemoteWatcher
-
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 interfaceActor
- Overrides:
receive
in classRemoteWatcher
- 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 classRemoteWatcher
-
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)
-
-