org.apache.reef.runtime.mesos.util

Class MesosRemoteManager

java.lang.Object

org.apache.reef.runtime.mesos.util.MesosRemoteManager

public final class MesosRemoteManager
extends Object

Since the existing RemoteManager cannot use an additional codec, we need this additional RemoteManager to use MesosMessageCodec. TODO[JIRA REEF-103]: Replace this class once Tang's namespace feature is enabled

Method Summary

Methods

Modifier and Type	Method and Description
<T> EventHandler<T>	getHandler(String destinationIdentifier, Class<? extends T> messageType)
String	getMyIdentifier()
<T,U extends T> AutoCloseable	registerHandler(Class<U> messageType, EventHandler<RemoteMessage<T>> theHandler)

Methods inherited from class java.lang.Object

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

Method Detail

getHandler

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

registerHandler

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

getMyIdentifier

public String getMyIdentifier()