edu.iu.dsc.tws.api.compute

Class TaskMessage<T>

java.lang.Object

edu.iu.dsc.tws.api.compute.TaskMessage<T>

All Implemented Interfaces:

IMessage<T>

public class TaskMessage<T>
extends java.lang.Object
implements IMessage<T>

Message implementation. A task should use this message to send and receive.

Constructor Summary

Constructors

Constructor and Description
TaskMessage(T data) Create a task message with data
TaskMessage(T content, int flag, java.lang.String edge, int sourceTask) Create a task message with data
TaskMessage(T content, java.lang.String edge, int sourceTask) Create a task message with data

Method Summary

Modifier and Type	Method and Description
java.lang.String	edge() The edge this message is traveling
T	getContent() Returns the content of the message
int	getFlag() Returns the flag of the message
void	setContent(T content)
void	setFlag(int flag) Set a flag to the message
int	sourceTask() Get the source of the message

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMessage

public TaskMessage(T data)

Create a task message with data

Parameters:

data - data

TaskMessage

public TaskMessage(T content,
                   java.lang.String edge,
                   int sourceTask)

Create a task message with data

Parameters:

content - data

edge - edge

sourceTask - sourcetask

TaskMessage

public TaskMessage(T content,
                   int flag,
                   java.lang.String edge,
                   int sourceTask)

Create a task message with data

Parameters:

content - content of the message

flag - flag

edge - edge

sourceTask - source task

Method Detail

getContent

public T getContent()

Description copied from interface: IMessage

Returns the content of the message

Specified by:

getContent in interface IMessage<T>

Returns:

content of the message

setContent

public void setContent(T content)

edge

public java.lang.String edge()

Description copied from interface: IMessage

The edge this message is traveling

Specified by:

edge in interface IMessage<T>

Returns:

the edge identifier

getFlag

public int getFlag()

Description copied from interface: IMessage

Returns the flag of the message

Specified by:

getFlag in interface IMessage<T>

Returns:

flag of the message

sourceTask

public int sourceTask()

Description copied from interface: IMessage

Get the source of the message

Specified by:

sourceTask in interface IMessage<T>

Returns:

source id

setFlag

public void setFlag(int flag)

Description copied from interface: IMessage

Set a flag to the message

Specified by:

setFlag in interface IMessage<T>

Parameters:

flag - barrier message