java.lang.Object
- akka.cluster.CrossDcHeartbeatSender

All Implemented Interfaces:

Actor, ActorLogging
```
public class CrossDcHeartbeatSender
extends java.lang.Object
implements Actor, ActorLogging
```
Looks up and returns the remote cluster heartbeat connection for the specific address.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`static interface`	`CrossDcHeartbeatSender.InspectionCommand`
`static class`	`CrossDcHeartbeatSender.MonitoringActive`
`static class`	`CrossDcHeartbeatSender.MonitoringActive$`
`static class`	`CrossDcHeartbeatSender.MonitoringDormant`
`static class`	`CrossDcHeartbeatSender.MonitoringDormant$`
`static interface`	`CrossDcHeartbeatSender.MonitoringStateReport`
`static class`	`CrossDcHeartbeatSender.ReportStatus`
`static class`	`CrossDcHeartbeatSender.ReportStatus$`
`static interface`	`CrossDcHeartbeatSender.StatusReport`

Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors
Constructor Description

CrossDcHeartbeatSender()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>`	`active()`
`boolean`	`activelyMonitoring()`
`void`	`activelyMonitoring_$eq(boolean x$1)`
`void`	`addMember(Member m)`
`protected void`	`akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)`
`protected void`	`akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)`	The 'self' field holds the ActorRef for this actor.
`Cluster`	`cluster()`
`ActorContext`	`context()`	Scala API: Stores the context for this actor, including self, and sender.
`FailureDetectorRegistry<Address>`	`crossDcFailureDetector()`
`ClusterSettings.CrossDcFailureDetectorSettings`	`crossDcSettings()`
`CrossDcHeartbeatingState`	`dataCentersState()`
`void`	`dataCentersState_$eq(CrossDcHeartbeatingState x$1)`
`scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>`	`dormant()`	In this state no cross-datacenter heartbeats are sent by this actor.
`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>`	`introspecting()`
`scala.Function1<Member,java.lang.Object>`	`isExternalClusterMember()`
`ClusterHeartbeatSender.Heartbeat`	`nextHeartBeat()`
`void`	`postStop()`	User overridable callback.
`void`	`preStart()`	User overridable callback.
`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.
`void`	`removeMember(Member m)`
`ActorRef`	`self()`	The 'self' field holds the ActorRef for this actor.
`long`	`sequenceNr()`
`void`	`sequenceNr_$eq(long x$1)`
`void`	`triggerFirstHeartbeat(UniqueAddress from)`
`boolean`	`verboseHeartbeat()`

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
  - CrossDcHeartbeatSender
```
public CrossDcHeartbeatSender()
```
- Method Detail
  - context
```
public ActorContext context()
```
    Description copied from interface: Actor
    
    Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as 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 AbstractActor.ActorContext, which is the Java API of the actor context.
    
    Specified by:
    
    context in interface Actor
    
    Returns:
    
    (undocumented)
  - self
```
public final ActorRef self()
```
    Description copied from interface: Actor
    The 'self' field holds the ActorRef for this actor.
    Can be used to send messages to itself:
    self ! message
    Specified by:
    
    self in interface Actor
    
    Returns:
    
    (undocumented)
  - akka$actor$Actor$_setter_$context_$eq
```
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
```
    Specified by:
    
    akka$actor$Actor$_setter_$context_$eq in interface Actor
  - akka$actor$Actor$_setter_$self_$eq
```
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
```
    Description copied from interface: Actor
    The 'self' field holds the ActorRef for this actor.
    Can be used to send messages to itself:
    self ! message
    Specified by:
    
    akka$actor$Actor$_setter_$self_$eq in interface Actor
    
    Parameters:
    
    x$1 - (undocumented)
  - cluster
```
public Cluster cluster()
```
  - verboseHeartbeat
```
public boolean verboseHeartbeat()
```
  - activelyMonitoring
```
public boolean activelyMonitoring()
```
  - activelyMonitoring_$eq
```
public void activelyMonitoring_$eq(boolean x$1)
```
  - isExternalClusterMember
```
public scala.Function1<Member,java.lang.Object> isExternalClusterMember()
```
  - crossDcSettings
```
public ClusterSettings.CrossDcFailureDetectorSettings crossDcSettings()
```
  - crossDcFailureDetector
```
public FailureDetectorRegistry<Address> crossDcFailureDetector()
```
  - sequenceNr
```
public long sequenceNr()
```
  - sequenceNr_$eq
```
public void sequenceNr_$eq(long x$1)
```
  - nextHeartBeat
```
public ClusterHeartbeatSender.Heartbeat nextHeartBeat()
```
  - dataCentersState
```
public CrossDcHeartbeatingState dataCentersState()
```
  - dataCentersState_$eq
```
public void dataCentersState_$eq(CrossDcHeartbeatingState x$1)
```
  - 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
    
    Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
    
    Specified by:
    
    receive in interface Actor
    
    Returns:
    
    (undocumented)
  - dormant
```
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> dormant()
```
    In this state no cross-datacenter heartbeats are sent by this actor. This may be because one of those reasons: - no nodes in other DCs were detected yet - nodes in other DCs are present, but this node is not tht n-th oldest in this DC (see number-of-cross-datacenter-monitoring-actors), so it does not have to monitor that other data centers
    In this state it will however listen to cluster events to eventually take over monitoring other DCs in case it becomes "old enough".
    
    Returns:
    
    (undocumented)
  - active
```
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> active()
```
  - introspecting
```
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> introspecting()
```
  - init
```
public void init(ClusterEvent.CurrentClusterState snapshot)
```
  - addMember
```
public void addMember(Member m)
```
  - removeMember
```
public void removeMember(Member m)
```
  - heartbeat
```
public void heartbeat()
```
  - heartbeatRsp
```
public void heartbeatRsp(UniqueAddress from)
```
  - triggerFirstHeartbeat
```
public void triggerFirstHeartbeat(UniqueAddress from)
```

Class CrossDcHeartbeatSender

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface akka.actor.Actor

Methods inherited from interface akka.actor.ActorLogging

Constructor Detail

CrossDcHeartbeatSender

Method Detail

context

self

akka$actor$Actor$_setter_$context_$eq

akka$actor$Actor$_setter_$self_$eq

cluster

verboseHeartbeat

activelyMonitoring

activelyMonitoring_$eq

isExternalClusterMember

crossDcSettings

crossDcFailureDetector

sequenceNr

sequenceNr_$eq

nextHeartBeat

dataCentersState

dataCentersState_$eq

heartbeatTask

preStart

postStop

heartbeatReceiver

receive

dormant

active

introspecting

init

addMember

removeMember

heartbeat

heartbeatRsp

triggerFirstHeartbeat