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 final class DefaultRemoteManagerImplementation
extends Object
implements RemoteManager

Default remote manager implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static String	UNKNOWN_HOST_NAME Indicates a hostname that isn't set or known.

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.
<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.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

UNKNOWN_HOST_NAME

public static final String UNKNOWN_HOST_NAME

Indicates a hostname that isn't set or known.

See Also:

Constant Field Values

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

Type Parameters:

T - type of message

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

Type Parameters:

T - type of event

U - type of message

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

Type Parameters:

T - a type of remote message of event

U - a type of message

Parameters:

messageType - a message class type

theHandler - the 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

toString

public String toString()

Overrides:

toString in class Object