Class WorkItemExecutorObserver

java.lang.Object

org.tasktide.engine.observer.worker.ExecutorObserver<WorkItem,ItemTask>

org.tasktide.engine.observer.worker.executor.WorkItemExecutorObserver

All Implemented Interfaces:

WorkerObserver<WorkItem>, TaskTideWorkerUnit<WorkItem>

public class WorkItemExecutorObserver
extends ExecutorObserver<WorkItem,ItemTask>

WorkerObserver of ExecutorObserver to handle tasks around execution of WorkItem Workload

Field Summary

Fields inherited from class ExecutorObserver

logger

Constructor Summary

Constructors

Constructor	Description
WorkItemExecutorObserver()	Construct embedding logger

Method Summary

Modifier and Type	Method	Description
String	getName()	Return observer name
int	handleUnlocks(WorkItem task)	Handle unlocking sub task ItemTask, returning count of unlocked
ObserverResult	onTaskEnd(WorkItem task)	Handle task post processing
ObserverResult	onTaskProcessing(WorkItem task)	Monitor task until done, may want different ways later
ObserverResult	onTaskStart(WorkItem task)	Verify WorkItem has open tasks before processing
boolean	pollUntilDone(WorkItem task)	Poll a StateSummary of WorkItem until done

Methods inherited from class ExecutorObserver

getType, isOptional

Methods inherited from class Object

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

Constructor Details

WorkItemExecutorObserver

public WorkItemExecutorObserver()

Construct embedding logger

Method Details

onTaskProcessing

public ObserverResult onTaskProcessing(WorkItem task)

Monitor task until done, may want different ways later

Parameters:

task -

Returns:

public boolean

onTaskEnd

public ObserverResult onTaskEnd(WorkItem task)

Handle task post processing

Parameters:

task -

Returns:

public boolean

pollUntilDone

public boolean pollUntilDone(WorkItem task)

Poll a StateSummary of WorkItem until done

Parameters:

task -

Returns:

boolean

handleUnlocks

public int handleUnlocks(WorkItem task)

Handle unlocking sub task ItemTask, returning count of unlocked

Parameters:

task -

Returns:

int

onTaskStart

public ObserverResult onTaskStart(WorkItem task)

Verify WorkItem has open tasks before processing

Parameters:

task -

Returns:

boolean

getName

public String getName()

Return observer name

Returns: