Package org.apache.nemo.runtime.common.message

Class PersistentConnectionToMasterMap

java.lang.Object

org.apache.nemo.runtime.common.message.PersistentConnectionToMasterMap

public final class PersistentConnectionToMasterMap
extends java.lang.Object

Persistent connection for sending messages to master.

Method Summary

Modifier and Type	Method	Description
MessageSender<ControlMessage.Message>	getMessageSender(java.lang.String listenerId)	Get the message sender corresponding to the given listener ID.

Methods inherited from class java.lang.Object

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

Method Detail

getMessageSender

public MessageSender<ControlMessage.Message> getMessageSender(java.lang.String listenerId)

Get the message sender corresponding to the given listener ID.

Parameters:

listenerId - the ID of the listener.

Returns:

the message sender.