Package akka.cluster

Class ClusterHeartbeatSender

  • All Implemented Interfaces:
    Actor, ActorLogging

    public class ClusterHeartbeatSender
    extends java.lang.Object
    implements Actor, ActorLogging
    Looks up and returns the remote cluster heartbeat connection for the specific address.
    • Constructor Detail

      • ClusterHeartbeatSender

        public ClusterHeartbeatSender()
    • 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()
      • filterInternalClusterMembers

        public scala.Function1<Member,​java.lang.Object> filterInternalClusterMembers()
      • sequenceNr

        public int sequenceNr()
      • sequenceNr_$eq

        public void sequenceNr_$eq​(int x$1)
      • 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)
      • initializing

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> initializing()
      • active

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> active()
      • 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()
      • triggerFirstHeartbeat

        public void triggerFirstHeartbeat​(UniqueAddress from)