@DefaultImplementation(value=org.apache.reef.wake.remote.DefaultRemoteManagerFactory.class) public interface RemoteManagerFactory
Use when direct injection of the RemoteManager is impossible.
Modifier and Type | Method and Description |
---|---|
RemoteManager |
getInstance(String name) |
<T> RemoteManager |
getInstance(String name,
Codec<T> codec,
EventHandler<Throwable> errorHandler) |
<T> RemoteManager |
getInstance(String name,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler) |
<T> RemoteManager |
getInstance(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout)
The old constructor of DefaultRemoteManagerImplementation.
|
<T> RemoteManager |
getInstance(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout,
LocalAddressProvider localAddressProvider,
TcpPortProvider tcpPortProvider)
The all-out constructor of DefaultRemoteManagerImplementation.
|
RemoteManager getInstance(String name)
name
- the name of used by the returned RemoteManager to determine the address to bind to. to instantiate.<T> RemoteManager getInstance(String name, Codec<T> codec, EventHandler<Throwable> errorHandler)
T
- the message type sent / received by the returned RemoteManager.name
- the name of the returned RemoteManager to instantiate.codec
- the codec to use to decode the messages sent to / by this RemoteManager.errorHandler
- the error handler invoked for exceptions by the returned RemoteManager.<T> RemoteManager getInstance(String name, int listeningPort, Codec<T> codec, EventHandler<Throwable> errorHandler)
T
- the message type sent / received by the returned RemoteManager.name
- the name of the returned RemoteManager to instantiate.listeningPort
- the port on which the returned RemoteManager listens.codec
- the codec to use to decode the messages sent to / by this RemoteManager.errorHandler
- the error handler invoked for exceptions by the returned RemoteManager.<T> RemoteManager getInstance(String name, String hostAddress, int listeningPort, Codec<T> codec, EventHandler<Throwable> errorHandler, boolean orderingGuarantee, int numberOfTries, int retryTimeout)
T
- the message type sent / received by the returned RemoteManager.name
- the name of the returned RemoteManager to instantiate.hostAddress
- the address the returned RemoteManager binds to.listeningPort
- the port on which the returned RemoteManager listens.codec
- the codec to use to decode the messages sent to / by this RemoteManager.errorHandler
- the error handler invoked for exceptions by the returned RemoteManager.orderingGuarantee
- whether or not the returned RemoteManager should guarantee message orders.numberOfTries
- the number of retries before the returned RemoteManager declares sending a failure.retryTimeout
- the time (in ms) after which the returned RemoteManager considers a sending attempt
failed.<T> RemoteManager getInstance(String name, String hostAddress, int listeningPort, Codec<T> codec, EventHandler<Throwable> errorHandler, boolean orderingGuarantee, int numberOfTries, int retryTimeout, LocalAddressProvider localAddressProvider, TcpPortProvider tcpPortProvider)
T
- the message type sent / received by the returned RemoteManager.name
- the name of the returned RemoteManager to instantiate.hostAddress
- the address the returned RemoteManager binds to.listeningPort
- the port on which the returned RemoteManager listens.codec
- the codec to use to decode the messages sent to / by this RemoteManager.errorHandler
- the error handler invoked for exceptions by the returned RemoteManager.orderingGuarantee
- whether or not the returned RemoteManager should guarantee message orders.numberOfTries
- the number of retries before the returned RemoteManager declares sending a failure.retryTimeout
- the time (in ms) after which the returned RemoteManager considers a sending attempt
failed.localAddressProvider
- the LocalAddressProvider used by the returned RemoteManager to determine the address
to bind to.tcpPortProvider
- the TcpPortProvider used by the returned RemoteManager to determine the port
to listen to.Copyright © 2017 The Apache Software Foundation. All rights reserved.