Package org.apache.pekko.remote

Class FailureDetectorLoader

java.lang.Object

org.apache.pekko.remote.FailureDetectorLoader

public class FailureDetectorLoader
extends java.lang.Object

INTERNAL API

Utility class to create FailureDetector instances reflectively.

Constructor Summary

Constructors

Constructor	Description
FailureDetectorLoader()

Method Summary

Modifier and Type	Method	Description
static FailureDetector	apply(java.lang.String fqcn, com.typesafe.config.Config config, ActorContext ctx)	Loads and instantiates a given FailureDetector implementation.
static FailureDetector	load(java.lang.String fqcn, com.typesafe.config.Config config, ActorSystem system)	Loads and instantiates a given FailureDetector implementation.

Methods inherited from class java.lang.Object

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

Constructor Detail

FailureDetectorLoader

public FailureDetectorLoader()

Method Detail

load

public static FailureDetector load(java.lang.String fqcn,
                                   com.typesafe.config.Config config,
                                   ActorSystem system)

Loads and instantiates a given FailureDetector implementation. The class to be loaded must have a constructor that accepts a Config and an pekko.event.EventStream 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 implementation

system - ActorSystem to be used for loading the implementation

Returns:

A configured instance of the given FailureDetector implementation

apply

public static FailureDetector apply(java.lang.String fqcn,
                                    com.typesafe.config.Config config,
                                    ActorContext ctx)

Loads and instantiates a given FailureDetector implementation. The class to be loaded must have a constructor that accepts a Config and an pekko.event.EventStream parameter. Will throw ConfigurationException if the implementation cannot be loaded. Use load(java.lang.String, com.typesafe.config.Config, org.apache.pekko.actor.ActorSystem) if no implicit pekko.actor.ActorContext is available.

Parameters:

fqcn - Fully qualified class name of the implementation to be loaded.

config - Configuration that will be passed to the implementation

Returns: