public final class ClusterHeartbeatSender extends java.lang.Object implements 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$ |
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
ClusterHeartbeatSender() |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
active() |
void |
addMember(Member m) |
protected abstract static void |
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1) |
protected abstract static void |
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1) |
static void |
akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1) |
static LoggingAdapter |
akka$actor$ActorLogging$$_log() |
protected static void |
aroundPostRestart(java.lang.Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object msg) |
Cluster |
cluster() |
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
FailureDetectorRegistry<Address> |
failureDetector() |
void |
heartbeat() |
ActorSelection |
heartbeatReceiver(Address address)
Looks up and returns the remote cluster heartbeat connection for the specific address.
|
void |
heartbeatRsp(UniqueAddress from) |
Cancellable |
heartbeatTask() |
void |
init(ClusterEvent.CurrentClusterState snapshot) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
initializing() |
static LoggingAdapter |
log() |
static void |
postRestart(java.lang.Throwable reason) |
void |
postStop()
User overridable callback.
|
static void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
void |
preStart()
User overridable callback.
|
void |
reachableMember(Member m) |
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.
|
void |
removeMember(Member m) |
ActorRef |
self()
The 'self' field holds the ActorRef for this actor.
|
ClusterHeartbeatSender.Heartbeat |
selfHeartbeat() |
static ActorRef |
sender() |
ClusterHeartbeatSenderState |
state() |
static SupervisorStrategy |
supervisorStrategy() |
void |
triggerFirstHeartbeat(UniqueAddress from) |
static void |
unhandled(java.lang.Object message) |
void |
unreachableMember(Member m) |
boolean |
verboseHeartbeat() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled
log
public static final ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void aroundPostRestart(java.lang.Throwable reason)
public static SupervisorStrategy supervisorStrategy()
public static void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message) throws java.lang.Exception
java.lang.Exception
public static void postRestart(java.lang.Throwable reason) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
protected abstract static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected abstract static void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public static LoggingAdapter akka$actor$ActorLogging$$_log()
public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
public static LoggingAdapter log()
public ActorContext context()
Actor
forward
.
WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API. getContext
returns a
UntypedActorContext
, which is the Java API of the actor
context.
public final ActorRef self()
Actor
self ! message
public Cluster cluster()
public boolean verboseHeartbeat()
public FailureDetectorRegistry<Address> failureDetector()
public ClusterHeartbeatSender.Heartbeat selfHeartbeat()
public ClusterHeartbeatSenderState state()
public Cancellable heartbeatTask()
public void preStart()
Actor
public void postStop()
Actor
public ActorSelection heartbeatReceiver(Address address)
address
- (undocumented)public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
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)