org.apache.reef.runtime.common.driver.task

Class TaskMessageImpl

java.lang.Object

org.apache.reef.runtime.common.driver.task.TaskMessageImpl

All Implemented Interfaces:

TaskMessage, Message, Identifiable

public final class TaskMessageImpl
extends Object
implements TaskMessage

Constructor Summary

Constructors

Constructor and Description
TaskMessageImpl(byte[] theMessage, String taskId, String contextId, String theMessageSourceId)

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	get() Message payload
String	getContextId()
String	getId() Returns an identifier of this object
String	getMessageSourceID()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMessageImpl

public TaskMessageImpl(byte[] theMessage,
               String taskId,
               String contextId,
               String theMessageSourceId)

Method Detail

get

public byte[] get()

Description copied from interface: Message

Message payload

Specified by:

get in interface TaskMessage

Specified by:

get in interface Message

Returns:

the message.

getId

public String getId()

Description copied from interface: Identifiable

Returns an identifier of this object

Specified by:

getId in interface TaskMessage

Specified by:

getId in interface Identifiable

Returns:

the ID of the sending task.

getContextId

public String getContextId()

Specified by:

getContextId in interface TaskMessage

Returns:

the id of the context the sending task is running in.

getMessageSourceID

public final String getMessageSourceID()

Specified by:

getMessageSourceID in interface TaskMessage

Returns:

the ID of the TaskMessageSource