Package org.apache.nemo.runtime.master

Class BlockManagerMaster.BlockManagerMasterControlMessageReceiver

java.lang.Object

org.apache.nemo.runtime.master.BlockManagerMaster.BlockManagerMasterControlMessageReceiver

All Implemented Interfaces:

MessageListener<ControlMessage.Message>

Enclosing class:

BlockManagerMaster

public final class BlockManagerMaster.BlockManagerMasterControlMessageReceiver
extends java.lang.Object
implements MessageListener<ControlMessage.Message>

Handler for control messages received.

Constructor Summary

Constructors

Constructor	Description
BlockManagerMasterControlMessageReceiver()

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

BlockManagerMasterControlMessageReceiver

public BlockManagerMasterControlMessageReceiver()

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