public final class ClusterHeartbeatSender
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging
Modifier and Type | Class and Description |
---|---|
static class |
ClusterHeartbeatSender.ExpectedFirstHeartbeat |
static class |
ClusterHeartbeatSender.ExpectedFirstHeartbeat$ |
static class |
ClusterHeartbeatSender.Heartbeat
Sent at regular intervals for failure detection.
|
static class |
ClusterHeartbeatSender.Heartbeat$ |
static class |
ClusterHeartbeatSender.HeartbeatRsp
Sent as reply to
ClusterHeartbeatSender.Heartbeat messages. |
static class |
ClusterHeartbeatSender.HeartbeatRsp$ |
static class |
ClusterHeartbeatSender.HeartbeatTick$ |
Constructor and Description |
---|
ClusterHeartbeatSender() |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
active() |
void |
addMember(Member m) |
Cluster |
cluster() |
akka.remote.FailureDetectorRegistry<akka.actor.Address> |
failureDetector() |
void |
heartbeat() |
akka.actor.ActorSelection |
heartbeatReceiver(akka.actor.Address address)
Looks up and returns the remote cluster heartbeat connection for the specific address.
|
void |
heartbeatRsp(UniqueAddress from) |
akka.actor.Cancellable |
heartbeatTask() |
void |
init(ClusterEvent.CurrentClusterState snapshot) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
initializing() |
void |
postStop() |
void |
preStart() |
void |
reachableMember(Member m) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
void |
removeMember(Member m) |
ClusterHeartbeatSender.Heartbeat |
selfHeartbeat() |
ClusterHeartbeatSenderState |
state() |
void |
triggerFirstHeartbeat(UniqueAddress from) |
void |
unreachableMember(Member m) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public Cluster cluster()
public akka.remote.FailureDetectorRegistry<akka.actor.Address> failureDetector()
public ClusterHeartbeatSender.Heartbeat selfHeartbeat()
public ClusterHeartbeatSenderState state()
public akka.actor.Cancellable heartbeatTask()
public void preStart()
preStart
in interface akka.actor.Actor
public void postStop()
postStop
in interface akka.actor.Actor
public akka.actor.ActorSelection heartbeatReceiver(akka.actor.Address address)
address
- (undocumented)public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> initializing()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> active()
public void init(ClusterEvent.CurrentClusterState snapshot)
public void addMember(Member m)
public void removeMember(Member m)
public void unreachableMember(Member m)
public void reachableMember(Member m)
public void heartbeat()
public void heartbeatRsp(UniqueAddress from)
public void triggerFirstHeartbeat(UniqueAddress from)