Class WorkItemObserver

java.lang.Object

org.tasktide.engine.observer.ObserverChain<WorkItem>

org.tasktide.engine.observer.chain.WorkItemObserver

All Implemented Interfaces:

TaskTideEngineObserver<WorkItem>, TaskTideWorkerUnit<WorkItem>

public class WorkItemObserver
extends ObserverChain<WorkItem>

Coordinates the work across the WorkerObservers for the processing of WorkItem through the TaskTideEngineObserver chain for WorkItems

Field Summary

Fields inherited from class ObserverChain

observers

Constructor Summary

Constructors

Constructor	Description
WorkItemObserver()	Default constructor for simple test purposes
WorkItemObserver(int maxTime)	Construct with required arguments
WorkItemObserver(List<WorkItem> workload, int maxTime)	Construct with optional workload

Method Summary

Modifier and Type	Method	Description
WorkerObserver<WorkItem>	getObserver(String query)	Get lower level observer by simple class name
List<WorkerObserver<WorkItem>>	getObservers()	Get lower level observer

Methods inherited from class ObserverChain

onTaskEnd, onTaskProcessing, onTaskStart

Methods inherited from class Object

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

Constructor Details

WorkItemObserver

public WorkItemObserver()

Default constructor for simple test purposes

WorkItemObserver

public WorkItemObserver(int maxTime)

Construct with required arguments

Parameters:

maxTime -

WorkItemObserver

public WorkItemObserver(List<WorkItem> workload,
 int maxTime)

Construct with optional workload

Parameters:

workload -

maxTime -

Method Details

getObservers

public List<WorkerObserver<WorkItem>> getObservers()

Description copied from interface: TaskTideEngineObserver

Get lower level observer

Returns:

WorkerObserver for WorkItem/ItemTask

getObserver

public WorkerObserver<WorkItem> getObserver(String query)

Description copied from interface: TaskTideEngineObserver

Get lower level observer by simple class name

Parameters:

query -

Returns: