Package akka.remote

Class DeadlineFailureDetector

  • All Implemented Interfaces:

    public class DeadlineFailureDetector
    extends java.lang.Object
    implements FailureDetector
    Constructor that reads parameters from config. Expecting config properties named acceptable-heartbeat-pause.
    • Constructor Detail

      • DeadlineFailureDetector

        public DeadlineFailureDetector​(scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause,
                                       scala.concurrent.duration.FiniteDuration heartbeatInterval,
                                       FailureDetector.Clock clock)
      • DeadlineFailureDetector

        public DeadlineFailureDetector​(com.typesafe.config.Config config,
                                       EventStream ev)
    • Method Detail

      • acceptableHeartbeatPause

        public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()
      • heartbeat

        public final void heartbeat()
        Description copied from interface: FailureDetector
        Notifies the FailureDetector that a heartbeat arrived from the monitored resource. This causes the FailureDetector to update its state.
        Specified by:
        heartbeat in interface FailureDetector
      • heartbeatInterval

        public scala.concurrent.duration.FiniteDuration heartbeatInterval()
      • isMonitoring

        public boolean isMonitoring()
        Description copied from interface: FailureDetector
        Returns true if the failure detector has received any heartbeats and started monitoring of the resource.
        Specified by:
        isMonitoring in interface FailureDetector