Package akka.remote

Class DeadlineFailureDetector

java.lang.Object

akka.remote.DeadlineFailureDetector

All Implemented Interfaces:

FailureDetector

public class DeadlineFailureDetector
extends java.lang.Object
implements FailureDetector

Constructor that reads parameters from config. Expecting config properties named acceptable-heartbeat-pause.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.remote.FailureDetector

FailureDetector.Clock

Constructor Summary

Constructors

Constructor	Description
DeadlineFailureDetector(com.typesafe.config.Config config, EventStream ev)
DeadlineFailureDetector(scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, scala.concurrent.duration.FiniteDuration heartbeatInterval, FailureDetector.Clock clock)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.duration.FiniteDuration	acceptableHeartbeatPause()
void	heartbeat()	Notifies the FailureDetector that a heartbeat arrived from the monitored resource.
scala.concurrent.duration.FiniteDuration	heartbeatInterval()
boolean	isAvailable()
boolean	isMonitoring()	Returns true if the failure detector has received any heartbeats and started monitoring of the resource.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface FailureDetector

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

Returns:

(undocumented)