Package com.github.workerframework.api

Class TaskMessage

java.lang.Object

com.github.workerframework.api.TaskMessage

public final class TaskMessage
extends Object

The generic task message class to be serialised from or to a queue. This will contain the serialised worker-specific data inside.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	TASK_MESSAGE_VERSION

Constructor Summary

Constructors

Constructor	Description
TaskMessage()
TaskMessage(String taskId, String taskClassifier, int taskApiVersion, byte[] taskData, TaskStatus taskStatus, Map<String,byte[]> context)
TaskMessage(String taskId, String taskClassifier, int taskApiVersion, byte[] taskData, TaskStatus taskStatus, Map<String,byte[]> context, String to)
TaskMessage(String taskId, String taskClassifier, int taskApiVersion, byte[] taskData, TaskStatus taskStatus, Map<String,byte[]> context, String to, TrackingInfo tracking)
TaskMessage(String taskId, String taskClassifier, int taskApiVersion, byte[] taskData, TaskStatus taskStatus, Map<String,byte[]> context, String to, TrackingInfo tracking, TaskSourceInfo sourceInfo)
TaskMessage(String taskId, String taskClassifier, int taskApiVersion, byte[] taskData, TaskStatus taskStatus, Map<String,byte[]> context, String to, TrackingInfo tracking, TaskSourceInfo sourceInfo, String correlationId)

Method Summary

Modifier and Type	Method	Description
Map<String,byte[]>	getContext()
String	getCorrelationId()
Integer	getPriority()
TaskSourceInfo	getSourceInfo()
int	getTaskApiVersion()
String	getTaskClassifier()
byte[]	getTaskData()
String	getTaskId()
TaskStatus	getTaskStatus()
String	getTo()
TrackingInfo	getTracking()
int	getVersion()
void	setContext(Map<String,byte[]> context)
void	setCorrelationId(String correlationId)
void	setPriority(Integer priority)
void	setSourceInfo(TaskSourceInfo sourceInfo)
void	setTaskApiVersion(int taskApiVersion)
void	setTaskClassifier(String taskClassifier)
void	setTaskData(byte[] taskData)
void	setTaskId(String taskId)
void	setTaskStatus(TaskStatus taskStatus)
void	setTo(String to)
void	setTracking(TrackingInfo tracking)
void	setVersion(int version)

Methods inherited from class java.lang.Object

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

Field Details

TASK_MESSAGE_VERSION

public static final int TASK_MESSAGE_VERSION

See Also:

• Constant Field Values

Constructor Details

TaskMessage

public TaskMessage()

TaskMessage

public TaskMessage(String taskId,
 String taskClassifier,
 int taskApiVersion,
 byte[] taskData,
 TaskStatus taskStatus,
 Map<String,byte[]> context)

TaskMessage

public TaskMessage(String taskId,
 String taskClassifier,
 int taskApiVersion,
 byte[] taskData,
 TaskStatus taskStatus,
 Map<String,byte[]> context,
 String to)

TaskMessage

public TaskMessage(String taskId,
 String taskClassifier,
 int taskApiVersion,
 byte[] taskData,
 TaskStatus taskStatus,
 Map<String,byte[]> context,
 String to,
 TrackingInfo tracking)

TaskMessage

public TaskMessage(String taskId,
 String taskClassifier,
 int taskApiVersion,
 byte[] taskData,
 TaskStatus taskStatus,
 Map<String,byte[]> context,
 String to,
 TrackingInfo tracking,
 TaskSourceInfo sourceInfo)

TaskMessage

public TaskMessage(String taskId,
 String taskClassifier,
 int taskApiVersion,
 byte[] taskData,
 TaskStatus taskStatus,
 Map<String,byte[]> context,
 String to,
 TrackingInfo tracking,
 TaskSourceInfo sourceInfo,
 String correlationId)

Method Details

getVersion

public int getVersion()

setVersion

public void setVersion(int version)

getTaskId

public String getTaskId()

setTaskId

public void setTaskId(String taskId)

getTaskClassifier

public String getTaskClassifier()

setTaskClassifier

public void setTaskClassifier(String taskClassifier)

getTaskData

public byte[] getTaskData()

setTaskData

public void setTaskData(byte[] taskData)

getTaskStatus

public TaskStatus getTaskStatus()

setTaskStatus

public void setTaskStatus(TaskStatus taskStatus)

getTaskApiVersion

public int getTaskApiVersion()

setTaskApiVersion

public void setTaskApiVersion(int taskApiVersion)

getContext

public Map<String,byte[]> getContext()

setContext

public void setContext(Map<String,byte[]> context)

getTo

public String getTo()

setTo

public void setTo(String to)

getTracking

public TrackingInfo getTracking()

setTracking

public void setTracking(TrackingInfo tracking)

getSourceInfo

public TaskSourceInfo getSourceInfo()

setSourceInfo

public void setSourceInfo(TaskSourceInfo sourceInfo)

getPriority

public Integer getPriority()

setPriority

public void setPriority(Integer priority)

getCorrelationId

public String getCorrelationId()

setCorrelationId

public void setCorrelationId(String correlationId)