Package akka.remote

Class DefaultFailureDetectorRegistry<A>

  • All Implemented Interfaces:
    FailureDetectorRegistry<A>
    public class DefaultFailureDetectorRegistry<A>
extends java.lang.Object
implements FailureDetectorRegistry<A>
    A lock-less thread-safe implementation of FailureDetectorRegistry.

    param: detectorFactory By-name parameter that returns the failure detector instance to be used by a newly registered resource

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void heartbeat​(A resource)
      Records a heartbeat for a resource.
      boolean isAvailable​(A resource)
      Returns true if the resource is considered to be up and healthy and returns false otherwise.
      boolean isMonitoring​(A resource)
      Returns true if the failure detector has received any heartbeats and started monitoring of the resource.
      void remove​(A resource)
      Removes the heartbeat management for a resource.
      void reset()
      Removes all resources and any associated failure detector state.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • DefaultFailureDetectorRegistry

        public DefaultFailureDetectorRegistry​(scala.Function0<FailureDetector> detectorFactory)