org.apache.reef.runtime.common.utils

Class RemoteManager

java.lang.Object

org.apache.reef.runtime.common.utils.RemoteManager

public class RemoteManager
extends Object

Constructor Summary

Constructors

Constructor and Description
RemoteManager(RemoteManager raw, RemoteIdentifierFactory factory)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
<T> EventHandler<T>	getHandler(String destinationIdentifier, Class<? extends T> messageType)
String	getMyIdentifier()
RemoteManager	raw()
AutoCloseable	registerErrorHandler(EventHandler<Exception> theHandler)
<T,U extends T> AutoCloseable	registerHandler(Class<U> messageType, EventHandler<RemoteMessage<T>> theHandler)
<T,U extends T> AutoCloseable	registerHandler(String sourceIdentifier, Class<U> messageType, EventHandler<T> theHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteManager

@Inject
public RemoteManager(RemoteManager raw,
                    RemoteIdentifierFactory factory)

Method Detail

raw

public final RemoteManager raw()

close

public void close()
           throws Exception

Throws:

Exception

getHandler

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

registerHandler

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

registerHandler

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

registerErrorHandler

public AutoCloseable registerErrorHandler(EventHandler<Exception> theHandler)

getMyIdentifier

public String getMyIdentifier()