Package org.apache.pekko.remote
Class FailureDetectorLoader
java.lang.Object
org.apache.pekko.remote.FailureDetectorLoader
INTERNAL API
Utility class to create FailureDetector instances reflectively.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic FailureDetectorapply(String fqcn, com.typesafe.config.Config config, ActorContext ctx) Loads and instantiates a givenFailureDetectorimplementation.static FailureDetectorload(String fqcn, com.typesafe.config.Config config, ActorSystem system) Loads and instantiates a givenFailureDetectorimplementation.
-
Constructor Details
-
FailureDetectorLoader
public FailureDetectorLoader()
-
-
Method Details
-
load
public static FailureDetector load(String fqcn, com.typesafe.config.Config config, ActorSystem system) Loads and instantiates a givenFailureDetectorimplementation. The class to be loaded must have a constructor that accepts aConfigand anpekko.event.EventStreamparameter. 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
FailureDetectorimplementation
-
apply
public static FailureDetector apply(String fqcn, com.typesafe.config.Config config, ActorContext ctx) Loads and instantiates a givenFailureDetectorimplementation. The class to be loaded must have a constructor that accepts aConfigand anpekko.event.EventStreamparameter. Will throw ConfigurationException if the implementation cannot be loaded. Useload(java.lang.String, com.typesafe.config.Config, org.apache.pekko.actor.ActorSystem)if no implicitpekko.actor.ActorContextis available.- Parameters:
fqcn- Fully qualified class name of the implementation to be loaded.config- Configuration that will be passed to the implementation- Returns:
-