Package org.flowable.eventregistry.impl.management

Class DefaultEventRegistryChangeDetectionExecutor

java.lang.Object

org.flowable.eventregistry.impl.management.DefaultEventRegistryChangeDetectionExecutor

All Implemented Interfaces:

EventRegistryChangeDetectionExecutor

public class DefaultEventRegistryChangeDetectionExecutor
extends Object
implements EventRegistryChangeDetectionExecutor

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected Runnable	changeDetectionRunnable
protected long	delayInMs
protected EventRegistryChangeDetectionManager	eventRegistryChangeDetectionManager
protected long	initialDelayInMs
protected ScheduledExecutorService	scheduledExecutorService
protected String	threadName

Constructor Summary

Constructors

Constructor	Description
DefaultEventRegistryChangeDetectionExecutor(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager, long initialDelayInMs, long delayInMs)

Method Summary

Modifier and Type	Method	Description
protected Runnable	createChangeDetectionRunnable()
Runnable	getChangeDetectionRunnable()
EventRegistryChangeDetectionManager	getEventRegistryChangeDetectionManager()
ScheduledExecutorService	getScheduledExecutorService()
String	getThreadName()
void	initialize()	Will be called after the engine has booted up.
void	setChangeDetectionRunnable(Runnable changeDetectionRunnable)
void	setEventRegistryChangeDetectionManager(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager)
void	setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)
void	setThreadName(String threadName)
void	shutdown()	Will be called when the engine closes.

Methods inherited from class java.lang.Object

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

Field Details

eventRegistryChangeDetectionManager

protected EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager

initialDelayInMs

protected long initialDelayInMs

delayInMs

protected long delayInMs

scheduledExecutorService

protected ScheduledExecutorService scheduledExecutorService

threadName

protected String threadName

changeDetectionRunnable

protected Runnable changeDetectionRunnable

Constructor Details

DefaultEventRegistryChangeDetectionExecutor

public DefaultEventRegistryChangeDetectionExecutor(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager,
 long initialDelayInMs,
 long delayInMs)

Method Details

initialize

public void initialize()

Description copied from interface: EventRegistryChangeDetectionExecutor

Will be called after the engine has booted up. Any initialization logic can be placed here.

Specified by:

initialize in interface EventRegistryChangeDetectionExecutor

shutdown

public void shutdown()

Description copied from interface: EventRegistryChangeDetectionExecutor

Will be called when the engine closes. Any shutdown logic should be placed here.

Specified by:

shutdown in interface EventRegistryChangeDetectionExecutor

createChangeDetectionRunnable

protected Runnable createChangeDetectionRunnable()

getScheduledExecutorService

public ScheduledExecutorService getScheduledExecutorService()

setScheduledExecutorService

public void setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)

getThreadName

public String getThreadName()

setThreadName

public void setThreadName(String threadName)

getChangeDetectionRunnable

public Runnable getChangeDetectionRunnable()

setChangeDetectionRunnable

public void setChangeDetectionRunnable(Runnable changeDetectionRunnable)

getEventRegistryChangeDetectionManager

public EventRegistryChangeDetectionManager getEventRegistryChangeDetectionManager()

setEventRegistryChangeDetectionManager

public void setEventRegistryChangeDetectionManager(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager)

Specified by:

setEventRegistryChangeDetectionManager in interface EventRegistryChangeDetectionExecutor