Class WorkItemStateObserver

java.lang.Object

org.tasktide.engine.observer.worker.StateObserver<WorkItem>

org.tasktide.engine.observer.worker.stateobserver.WorkItemStateObserver

All Implemented Interfaces:

WorkerObserver<WorkItem>, TaskTideWorkerUnit<WorkItem>

public class WorkItemStateObserver
extends StateObserver<WorkItem>

Class for observing the processing of WorkItem

Field Summary

Fields inherited from class StateObserver

JOB_ENV_ID

Constructor Summary

Constructors

Constructor	Description
WorkItemStateObserver()	Construct with TaskTrackers
WorkItemStateObserver(List<WorkItem> workload)	Construct feeding WorkItem workload into TaskTrackers

Method Summary

Modifier and Type	Method	Description
String	getName()	Return observer name
ObserverResult	onTaskEnd(WorkItem task)	Handle assignment of ItemState.Done to WorkItem
ObserverResult	onTaskProcessing(WorkItem task)	Handles actions when task is being processed
ObserverResult	onTaskStart(WorkItem task)	Verify WorkItem availability before processing

Methods inherited from class StateObserver

getType, isOptional

Methods inherited from class Object

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

Constructor Details

WorkItemStateObserver

public WorkItemStateObserver()

Construct with TaskTrackers

WorkItemStateObserver

public WorkItemStateObserver(List<WorkItem> workload)

Construct feeding WorkItem workload into TaskTrackers

Parameters:

workload -

Method Details

onTaskStart

public ObserverResult onTaskStart(WorkItem task)

Verify WorkItem availability before processing

Parameters:

task -

Returns:

boolean

onTaskProcessing

public ObserverResult onTaskProcessing(WorkItem task)

Handles actions when task is being processed

Parameters:

task -

Returns:

ObserverResult

onTaskEnd

public ObserverResult onTaskEnd(WorkItem task)

Handle assignment of ItemState.Done to WorkItem

Parameters:

task -

Returns:

boolean

getName

public String getName()

Return observer name

Returns: