Package akka.remote
Class FailureDetectorLoader$
- java.lang.Object
-
- akka.remote.FailureDetectorLoader$
-
public class FailureDetectorLoader$ extends java.lang.Object
INTERNAL APIUtility class to create
FailureDetector
instances reflectively.
-
-
Field Summary
Fields Modifier and Type Field Description static FailureDetectorLoader$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description FailureDetectorLoader$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FailureDetector
apply(java.lang.String fqcn, com.typesafe.config.Config config, ActorContext ctx)
Loads and instantiates a givenFailureDetector
implementation.FailureDetector
load(java.lang.String fqcn, com.typesafe.config.Config config, ActorSystem system)
Loads and instantiates a givenFailureDetector
implementation.
-
-
-
Field Detail
-
MODULE$
public static final FailureDetectorLoader$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
load
public FailureDetector load(java.lang.String fqcn, com.typesafe.config.Config config, ActorSystem system)
Loads and instantiates a givenFailureDetector
implementation. The class to be loaded must have a constructor that accepts aConfig
and anEventStream
parameter. Will throw ConfigurationException if the implementation cannot be loaded.- Parameters:
fqcn
- Fully qualified class name of the implementation to be loaded.config
- Configuration that will be passed to the implementationsystem
- ActorSystem to be used for loading the implementation- Returns:
- A configured instance of the given
FailureDetector
implementation
-
apply
public FailureDetector apply(java.lang.String fqcn, com.typesafe.config.Config config, ActorContext ctx)
Loads and instantiates a givenFailureDetector
implementation. The class to be loaded must have a constructor that accepts aConfig
and anEventStream
parameter. Will throw ConfigurationException if the implementation cannot be loaded. UseFailureDetectorLoader.load(java.lang.String, com.typesafe.config.Config, akka.actor.ActorSystem)
if no implicitActorContext
is available.- Parameters:
fqcn
- Fully qualified class name of the implementation to be loaded.config
- Configuration that will be passed to the implementation- Returns:
-
-