akka.remote
Class FailureDetectorLoader

java.lang.Object
  extended by akka.remote.FailureDetectorLoader

public class FailureDetectorLoader
extends java.lang.Object

INTERNAL API

Utility class to create FailureDetector instances reflectively.


Constructor Summary
FailureDetectorLoader()
           
 
Method Summary
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 com.typesafe.config.Config and an 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 com.typesafe.config.Config and an EventStream parameter. Will throw ConfigurationException if the implementation cannot be loaded. Use load(java.lang.String, com.typesafe.config.Config, akka.actor.ActorSystem) if no implicit ActorContext is available.

Parameters:
fqcn - Fully qualified class name of the implementation to be loaded.
config - Configuration that will be passed to the implementation
ctx - (undocumented)
Returns: