Class ItemTaskObserver

java.lang.Object

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

org.tasktide.engine.observer.chain.ItemTaskObserver

All Implemented Interfaces:

TaskTideEngineObserver<ItemTask>, TaskTideWorkerUnit<ItemTask>

public class ItemTaskObserver
extends ObserverChain<ItemTask>

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

Field Summary

Fields inherited from class ObserverChain

observers

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
WorkerObserver<ItemTask>	getObserver(String query)	Get lower level observer by simple class name
List<WorkerObserver<ItemTask>>	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

ItemTaskObserver

public ItemTaskObserver()

Default constructor for simple test purposes

ItemTaskObserver

public ItemTaskObserver(int maxTime)

Construct with required arguments

Parameters:

maxTime -

ItemTaskObserver

public ItemTaskObserver(List<ItemTask> workload,
 int maxTime)

Construct with required arguments

Parameters:

workload -

maxTime -

Method Details

getObservers

public List<WorkerObserver<ItemTask>> getObservers()

Description copied from interface: TaskTideEngineObserver

Get lower level observer

Returns:

WorkerObserver for WorkItem/ItemTask

getObserver

public WorkerObserver<ItemTask> getObserver(String query)

Description copied from interface: TaskTideEngineObserver

Get lower level observer by simple class name

Parameters:

query -

Returns: