Package org.apache.nemo.runtime.master

Class PipeManagerMaster.PipeManagerMasterControlMessageReceiver

java.lang.Object

org.apache.nemo.runtime.master.PipeManagerMaster.PipeManagerMasterControlMessageReceiver

All Implemented Interfaces:

MessageListener<ControlMessage.Message>

Enclosing class:

PipeManagerMaster

public final class PipeManagerMaster.PipeManagerMasterControlMessageReceiver
extends java.lang.Object
implements MessageListener<ControlMessage.Message>

Handler for control messages received.

Constructor Summary

Constructors

Constructor	Description
PipeManagerMasterControlMessageReceiver()

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

PipeManagerMasterControlMessageReceiver

public PipeManagerMasterControlMessageReceiver()

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