org.apache.reef.wake.remote.impl

Class DefaultRemoteManagerImplementation

java.lang.Object

org.apache.reef.wake.remote.impl.DefaultRemoteManagerImplementation

All Implemented Interfaces:

AutoCloseable, RemoteManager, Stage

public class DefaultRemoteManagerImplementation
extends Object
implements RemoteManager

Default remote manager implementation

Constructor Summary

Constructors

Constructor and Description
DefaultRemoteManagerImplementation(String name, String hostAddress, int listeningPort, Codec<T> codec, EventHandler<Throwable> errorHandler, boolean orderingGuarantee, int numberOfTries, int retryTimeout)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
<T> EventHandler<T>	getHandler(RemoteIdentifier destinationIdentifier, Class<? extends T> messageType) Returns a proxy event handler for a remote identifier and a message type
RemoteIdentifier	getMyIdentifier() Returns my identifier
AutoCloseable	registerErrorHandler(EventHandler<Exception> theHandler) Registers an exception handler and returns a subscription
<T,U extends T> AutoCloseable	registerHandler(Class<U> messageType, EventHandler<RemoteMessage<T>> theHandler) Registers an event handler for a message type and returns a subscription
<T,U extends T> AutoCloseable	registerHandler(RemoteIdentifier sourceIdentifier, Class<U> messageType, EventHandler<T> theHandler) Registers an event handler for a remote identifier and a message type and returns a subscription

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRemoteManagerImplementation

@Inject
public DefaultRemoteManagerImplementation(String name,
                                         String hostAddress,
                                         int listeningPort,
                                         Codec<T> codec,
                                         EventHandler<Throwable> errorHandler,
                                         boolean orderingGuarantee,
                                         int numberOfTries,
                                         int retryTimeout)

Method Detail

getHandler

public <T> EventHandler<T> getHandler(RemoteIdentifier destinationIdentifier,
                             Class<? extends T> messageType)

Returns a proxy event handler for a remote identifier and a message type

Specified by:

getHandler in interface RemoteManager

Parameters:

destinationIdentifier - a destination identifier

messageType - a message class type

Returns:

an event handler

registerHandler

public <T,U extends T> AutoCloseable registerHandler(RemoteIdentifier sourceIdentifier,
                                            Class<U> messageType,
                                            EventHandler<T> theHandler)

Registers an event handler for a remote identifier and a message type and returns a subscription

Specified by:

registerHandler in interface RemoteManager

Parameters:

sourceIdentifier - a source identifier

messageType - a message class type

theHandler - the event handler

Returns:

the subscription that can be used to unsubscribe later

registerHandler

public <T,U extends T> AutoCloseable registerHandler(Class<U> messageType,
                                            EventHandler<RemoteMessage<T>> theHandler)

Registers an event handler for a message type and returns a subscription

Specified by:

registerHandler in interface RemoteManager

Parameters:

messageType - a message class type

theHandler - the event handler

Returns:

the subscription that can be used to unsubscribe later

registerErrorHandler

public AutoCloseable registerErrorHandler(EventHandler<Exception> theHandler)

Registers an exception handler and returns a subscription

Specified by:

registerErrorHandler in interface RemoteManager

Parameters:

theHandler - the exception event handler

Returns:

the subscription that can be used to unsubscribe later

getMyIdentifier

public RemoteIdentifier getMyIdentifier()

Returns my identifier

Specified by:

getMyIdentifier in interface RemoteManager

Returns:

the Identifier of this.

close

public void close()

Specified by:

close in interface AutoCloseable