Package org.flowable.external.worker.listener

Class WorkerJobListenerContainer.ListenerConsumer

java.lang.Object

org.flowable.external.worker.listener.WorkerJobListenerContainer.ListenerConsumer

All Implemented Interfaces:

Runnable, org.springframework.scheduling.SchedulingAwareRunnable

Enclosing class:

WorkerJobListenerContainer

protected class WorkerJobListenerContainer.ListenerConsumer
extends Object
implements org.springframework.scheduling.SchedulingAwareRunnable

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	index

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ListenerConsumer(int index)

Method Summary

Modifier and Type	Method	Description
protected void	doIdle()
protected void	doInvokeOnListener(AcquiredExternalWorkerJob job)
protected List<AcquiredExternalWorkerJob>	doPoll()
protected void	invokeIfHasJobs(List<AcquiredExternalWorkerJob> jobs)
protected void	invokeListener(List<AcquiredExternalWorkerJob> jobs)
boolean	isLongLived()
protected void	pollAndInvoke()
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

index

protected final int index

Constructor Details

ListenerConsumer

protected ListenerConsumer(int index)

Method Details

isLongLived

public boolean isLongLived()

Specified by:

isLongLived in interface org.springframework.scheduling.SchedulingAwareRunnable

run

public void run()

Specified by:

run in interface Runnable

pollAndInvoke

protected void pollAndInvoke()

doPoll

protected List<AcquiredExternalWorkerJob> doPoll()

invokeIfHasJobs

protected void invokeIfHasJobs(List<AcquiredExternalWorkerJob> jobs)

doIdle

protected void doIdle()

invokeListener

protected void invokeListener(List<AcquiredExternalWorkerJob> jobs)

doInvokeOnListener

protected void doInvokeOnListener(AcquiredExternalWorkerJob job)

toString

public String toString()

Overrides:

toString in class Object