|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectakka.remote.RemoteWatcher
akka.cluster.ClusterRemoteWatcher
public class ClusterRemoteWatcher
INTERNAL API
Specialization of RemoteWatcher
that keeps
track of cluster member nodes and is responsible for watchees on cluster nodes.
akka.actor.AddressTerminate
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.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Constructor Summary | |
---|---|
ClusterRemoteWatcher(FailureDetectorRegistry<Address> failureDetector,
scala.concurrent.duration.FiniteDuration heartbeatInterval,
scala.concurrent.duration.FiniteDuration unreachableReaperInterval,
scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)
|
Method Summary | |
---|---|
Cluster |
cluster()
|
scala.collection.immutable.Set<Address> |
clusterNodes()
|
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)
Factory method for ClusterRemoteWatcher Props . |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
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. |
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 |
Methods inherited from interface akka.actor.ActorLogging |
---|
_log, log |
Constructor Detail |
---|
public ClusterRemoteWatcher(FailureDetectorRegistry<Address> failureDetector, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration unreachableReaperInterval, scala.concurrent.duration.FiniteDuration heartbeatExpectedResponseAfter)
Method Detail |
---|
public static Props props(FailureDetectorRegistry<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<Address> clusterNodes()
public void preStart()
Actor
public void postStop()
Actor
postStop
in interface Actor
postStop
in class RemoteWatcher
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
receive
in interface Actor
receive
in class RemoteWatcher
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveClusterEvent()
public void takeOverResponsibility(Address address)
address
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |