akka.cluster
Class ClusterHeartbeatSender
java.lang.Object
akka.cluster.ClusterHeartbeatSender
- All Implemented Interfaces:
- Actor, ActorLogging
public final class ClusterHeartbeatSender
- extends java.lang.Object
- implements Actor, ActorLogging
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 |
ClusterHeartbeatSender
public ClusterHeartbeatSender()
cluster
public Cluster cluster()
failureDetector
public FailureDetectorRegistry<Address> failureDetector()
selfHeartbeat
public ClusterHeartbeatSender.Heartbeat selfHeartbeat()
state
public ClusterHeartbeatSenderState state()
heartbeatTask
public Cancellable heartbeatTask()
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.
- Specified by:
preStart
in interface Actor
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
heartbeatReceiver
public ActorSelection heartbeatReceiver(Address address)
- Looks up and returns the remote cluster heartbeat connection for the specific address.
- Parameters:
address
- (undocumented)
- Returns:
- (undocumented)
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
- Returns:
- (undocumented)
initializing
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> initializing()
active
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> active()
init
public void init(ClusterEvent.CurrentClusterState snapshot)
addMember
public void addMember(Member m)
removeMember
public void removeMember(Member m)
unreachableMember
public void unreachableMember(Member m)
reachableMember
public void reachableMember(Member m)
heartbeat
public void heartbeat()
heartbeatRsp
public void heartbeatRsp(UniqueAddress from)
triggerFirstHeartbeat
public void triggerFirstHeartbeat(UniqueAddress from)