Package org.flowable.eventregistry.spring.management

Class DefaultSpringEventRegistryChangeDetectionExecutor

java.lang.Object

org.flowable.eventregistry.spring.management.DefaultSpringEventRegistryChangeDetectionExecutor

All Implemented Interfaces:

EventRegistryChangeDetectionExecutor, DisposableBean

public class DefaultSpringEventRegistryChangeDetectionExecutor
extends Object
implements EventRegistryChangeDetectionExecutor, DisposableBean

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected Duration	delay
protected EventRegistryChangeDetectionManager	eventRegistryChangeDetectionManager
protected Duration	initialDelay
protected TaskScheduler	taskScheduler
protected ThreadPoolTaskScheduler	threadPoolTaskScheduler

Constructor Summary

Constructors

Constructor	Description
DefaultSpringEventRegistryChangeDetectionExecutor(long initialDelayInMs, long delayInMs)
DefaultSpringEventRegistryChangeDetectionExecutor(long initialDelayInMs, long delayInMs, TaskScheduler taskScheduler)

Method Summary

Modifier and Type	Method	Description
protected Runnable	createChangeDetectionRunnable()
protected void	createDefaultTaskScheduler()
void	destroy()
EventRegistryChangeDetectionManager	getEventRegistryChangeDetectionManager()
TaskScheduler	getTaskScheduler()
void	initialize()	Will be called after the engine has booted up.
void	setEventRegistryChangeDetectionManager(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager)
void	setTaskScheduler(TaskScheduler taskScheduler)
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

initialDelay

protected Duration initialDelay

delay

protected Duration delay

taskScheduler

protected TaskScheduler taskScheduler

threadPoolTaskScheduler

protected ThreadPoolTaskScheduler threadPoolTaskScheduler

eventRegistryChangeDetectionManager

protected EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager

Constructor Details

DefaultSpringEventRegistryChangeDetectionExecutor

public DefaultSpringEventRegistryChangeDetectionExecutor(long initialDelayInMs,
 long delayInMs)

DefaultSpringEventRegistryChangeDetectionExecutor

public DefaultSpringEventRegistryChangeDetectionExecutor(long initialDelayInMs,
 long delayInMs,
 TaskScheduler taskScheduler)

Method Details

createDefaultTaskScheduler

protected void createDefaultTaskScheduler()

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

createChangeDetectionRunnable

protected Runnable createChangeDetectionRunnable()

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

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

getEventRegistryChangeDetectionManager

public EventRegistryChangeDetectionManager getEventRegistryChangeDetectionManager()

setEventRegistryChangeDetectionManager

public void setEventRegistryChangeDetectionManager(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager)

Specified by:

setEventRegistryChangeDetectionManager in interface EventRegistryChangeDetectionExecutor

getTaskScheduler

public TaskScheduler getTaskScheduler()

setTaskScheduler

public void setTaskScheduler(TaskScheduler taskScheduler)