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

Class ClientRPC

java.lang.Object

org.apache.nemo.runtime.common.message.ClientRPC

public final class ClientRPC
extends java.lang.Object

Driver-side RPC implementation for communication from/to Nemo Client.

Method Summary

Modifier and Type	Method	Description
ClientRPC	registerHandler(ControlMessage.ClientToDriverMessageType type, org.apache.reef.wake.EventHandler<ControlMessage.ClientToDriverMessage> handler)	Registers handler for the given type of message.
void	send(ControlMessage.DriverToClientMessage message)	Write message to client.
void	shutdown()	Shuts down the transport.

Methods inherited from class java.lang.Object

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

Method Detail

registerHandler

public ClientRPC registerHandler(ControlMessage.ClientToDriverMessageType type,
                                 org.apache.reef.wake.EventHandler<ControlMessage.ClientToDriverMessage> handler)

Registers handler for the given type of message.

Parameters:

type - the type of message

handler - handler implementation

Returns:

this

shutdown

public void shutdown()

Shuts down the transport.

send

public void send(ControlMessage.DriverToClientMessage message)

Write message to client.

Parameters:

message - message to send.