org.apache.reef.task

Class TaskMessage

java.lang.Object

org.apache.reef.task.TaskMessage

All Implemented Interfaces:

Message

public final class TaskMessage
extends Object
implements Message

A message sent from a Task to a Driver.

Method Summary

Methods

Modifier and Type	Method and Description
static TaskMessage	from(String messageSourceID, byte[] theBytes)
byte[]	get() Message payload
String	getMessageSourceID()

Methods inherited from class java.lang.Object

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

Method Detail

from

public static TaskMessage from(String messageSourceID,
               byte[] theBytes)

Parameters:

messageSourceID - The message's sourceID. This will be accessible in the Driver for routing.

theBytes - The actual content of the message, serialized into a byte[]

Returns:

a new TaskMessage with the given content.

getMessageSourceID

public String getMessageSourceID()

Returns:

the message source identifier.

get

public byte[] get()

Description copied from interface: Message

Message payload

Specified by:

get in interface Message

Returns:

the message