Package org.apache.nemo.runtime.master

Class RuntimeMaster.MasterControlMessageReceiver

java.lang.Object

org.apache.nemo.runtime.master.RuntimeMaster.MasterControlMessageReceiver

All Implemented Interfaces:

MessageListener<ControlMessage.Message>

Enclosing class:

RuntimeMaster

public final class RuntimeMaster.MasterControlMessageReceiver
extends java.lang.Object
implements MessageListener<ControlMessage.Message>

Handler for control messages received by Master.

Constructor Summary

Constructors

Constructor	Description
MasterControlMessageReceiver()

Method Summary

Modifier and Type	Method	Description
void	onMessage(ControlMessage.Message message)	Called back when a message is received.
void	onMessageWithContext(ControlMessage.Message message, MessageContext messageContext)	Called back when a message is received, and return a response using MessageContext.

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterControlMessageReceiver

public MasterControlMessageReceiver()

Method Detail

onMessage

public void onMessage(ControlMessage.Message message)

Description copied from interface: MessageListener

Called back when a message is received.

Specified by:

onMessage in interface MessageListener<ControlMessage.Message>

Parameters:

message - a message

onMessageWithContext

public void onMessageWithContext(ControlMessage.Message message,
                                 MessageContext messageContext)

Description copied from interface: MessageListener

Called back when a message is received, and return a response using MessageContext.

Specified by:

onMessageWithContext in interface MessageListener<ControlMessage.Message>

Parameters:

message - a message

messageContext - a message context