Class ObserverChain<T extends TaskTideModel<T>>

java.lang.Object

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

Type Parameters:

T - of TaskTideModel-WorkItem,ItemTask

All Implemented Interfaces:

TaskTideEngineObserver<T>, TaskTideWorkerUnit<T>

Direct Known Subclasses:

ItemTaskObserver, WorkItemObserver

public abstract class ObserverChain<T extends TaskTideModel<T>>
extends Object
implements TaskTideEngineObserver<T>

Holds each WorkerObserver in a list, with onStart, onProcessing, and onEnd methods operating iteratively where the failure of one breaks exeuction chain. To context failure methods a ObserverResult are returned.

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<WorkerObserver<T>>	observers

Constructor Summary

Constructors

Constructor	Description
ObserverChain(List<WorkerObserver<T>> observers)	Construct with WorkerObserver list

Method Summary

Modifier and Type	Method	Description
boolean	onTaskEnd(T task)	Run the onTaskEnd method from each WorkerObserver.
boolean	onTaskProcessing(T task)	Run the onTaskProcessing method from each WorkerObserver.
boolean	onTaskStart(T task)	Run the onTaskStart method from each WorkerObserver.

Methods inherited from class Object

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

Methods inherited from interface TaskTideEngineObserver

getObserver, getObservers

Field Details

observers

protected final List<WorkerObserver<T extends TaskTideModel<T>>> observers

Constructor Details

ObserverChain

public ObserverChain(List<WorkerObserver<T>> observers)

Construct with WorkerObserver list

Parameters:

observers -

Method Details

onTaskStart

public boolean onTaskStart(T task)

Run the onTaskStart method from each WorkerObserver. Returning ObserverResult flagging failed observer, or successful run.

Specified by:

onTaskStart in interface TaskTideEngineObserver<T extends TaskTideModel<T>>

Parameters:

task -

Returns:

ObserverResult

onTaskProcessing

public boolean onTaskProcessing(T task)

Run the onTaskProcessing method from each WorkerObserver. Returning ObserverResult flagging failed observer, or successful run.

Specified by:

onTaskProcessing in interface TaskTideEngineObserver<T extends TaskTideModel<T>>

Parameters:

task -

Returns:

ObserverResult

onTaskEnd

public boolean onTaskEnd(T task)

Run the onTaskEnd method from each WorkerObserver. Returning ObserverResult flagging failed observer, or successful run.

Specified by:

onTaskEnd in interface TaskTideEngineObserver<T extends TaskTideModel<T>>

Parameters:

task -

Returns:

ObserverResult