Package akka.cluster

Class CrossDcHeartbeatSender

  • All Implemented Interfaces:
    Actor, ActorLogging

    public final class CrossDcHeartbeatSender
    extends java.lang.Object
    implements Actor, ActorLogging
    Looks up and returns the remote cluster heartbeat connection for the specific address.
    • 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_$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()
      • 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()
      • 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)