Class SpringAsyncHistoryExecutor

java.lang.Object

org.flowable.job.service.impl.asyncexecutor.AbstractAsyncExecutor

org.flowable.job.service.impl.asyncexecutor.DefaultAsyncJobExecutor

org.flowable.spring.job.service.SpringAsyncExecutor

org.flowable.spring.job.service.SpringAsyncHistoryExecutor

All Implemented Interfaces:

AsyncExecutor

public class SpringAsyncHistoryExecutor
extends SpringAsyncExecutor

Nested Class Summary

Nested classes/interfaces inherited from class AbstractAsyncExecutor

AbstractAsyncExecutor.AcquireAsyncJobsDueRunnableConfiguration, AbstractAsyncExecutor.AcquireTimerRunnableConfiguration

Field Summary

Fields inherited from class SpringAsyncExecutor

rejectedJobsHandler

Fields inherited from class DefaultAsyncJobExecutor

asyncJobAcquisitionThread, resetExpiredJobThread, shutdownTaskExecutor, taskExecutor, timerJobAcquisitionThread

Fields inherited from class AbstractAsyncExecutor

asyncJobsDueLifecycleListener, asyncJobsDueRunnable, asyncRunnableExecutionExceptionHandler, configuration, executeAsyncRunnableFactory, isActive, isAutoActivate, jobEntityManager, jobExecutionObservationProvider, jobServiceConfiguration, resetExpiredJobsRunnable, temporaryJobQueue, timerJobRunnable, timerLifecycleListener

Constructor Summary

Constructors

Constructor	Description
SpringAsyncHistoryExecutor()
SpringAsyncHistoryExecutor(AsyncJobExecutorConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
protected ResetExpiredJobsRunnable	createResetExpiredJobsRunnable(String resetRunnableName)
protected void	init()
protected void	initializeJobEntityManager()

Methods inherited from class SpringAsyncExecutor

executeAsyncJob, getRejectedJobsHandler, initAsyncJobExecutionThreadPool, setRejectedJobsHandler

Methods inherited from class DefaultAsyncJobExecutor

executeAsyncJob, getAsyncJobAcquisitionThread, getResetExpiredJobThread, getTaskExecutor, getTimerJobAcquisitionThread, isAsyncJobAcquisitionEnabled, isResetExpiredJobEnabled, isTimerJobAcquisitionEnabled, isUnlockOwnedJobs, sendRejectedEvent, setAsyncJobAcquisitionEnabled, setAsyncJobAcquisitionThread, setResetExpiredJobEnabled, setResetExpiredJobThread, setTaskExecutor, setTimerJobAcquisitionEnabled, setTimerJobAcquisitionThread, setUnlockOwnedJobs, shutdownAdditionalComponents, startAdditionalComponents, startJobAcquisitionThread, startResetExpiredJobsThread, startTimerAcquisitionThread, stopExecutingAsyncJobs, stopJobAcquisitionThread, stopResetExpiredJobsThread, stopTimerAcquisitionThread, unacquireJobAfterRejection

Methods inherited from class AbstractAsyncExecutor

createRunnableForJob, executeTemporaryJobs, getAsyncJobLockTimeInMillis, getAsyncJobsDueLifecycleListener, getAsyncJobsDueRunnable, getAsyncJobsGlobalLockPollRate, getAsyncJobsGlobalLockWaitTime, getAsyncRunnableExecutionExceptionHandler, getConfiguration, getDefaultAsyncJobAcquireWaitTimeInMillis, getDefaultQueueSizeFullWaitTimeInMillis, getDefaultTimerJobAcquireWaitTimeInMillis, getExecuteAsyncRunnableFactory, getGlobalAcquireLockPrefix, getJobExecutionObservationProvider, getJobServiceConfiguration, getLockOwner, getMaxAsyncJobsDuePerAcquisition, getMaxTimerJobsPerAcquisition, getMoveTimerExecutorPoolSize, getResetExpiredJobsInterval, getResetExpiredJobsPageSize, getResetExpiredJobsRunnable, getTenantId, getTimerJobRunnable, getTimerLifecycleListener, getTimerLockPollRate, getTimerLockTimeInMillis, getTimerLockWaitTime, initializeRunnables, isActive, isAutoActivate, isGlobalAcquireLockEnabled, isTimerRunnableNeeded, setAcquireRunnableThreadName, setAsyncJobLockTimeInMillis, setAsyncJobsDueLifecycleListener, setAsyncJobsDueRunnable, setAsyncJobsGlobalLockPollRate, setAsyncJobsGlobalLockWaitTime, setAsyncRunnableExecutionExceptionHandler, setAutoActivate, setConfiguration, setDefaultAsyncJobAcquireWaitTimeInMillis, setDefaultQueueSizeFullWaitTimeInMillis, setDefaultTimerJobAcquireWaitTimeInMillis, setExecuteAsyncRunnableFactory, setGlobalAcquireLockEnabled, setGlobalAcquireLockPrefix, setJobEntityManager, setJobExecutionObservationProvider, setJobServiceConfiguration, setLockOwner, setMaxAsyncJobsDuePerAcquisition, setMaxTimerJobsPerAcquisition, setMoveTimerExecutorPoolSize, setResetExpiredJobsInterval, setResetExpiredJobsPageSize, setResetExpiredJobsRunnable, setResetExpiredRunnableName, setTenantId, setTimerJobRunnable, setTimerLifecycleListener, setTimerLockPollRate, setTimerLockTimeInMillis, setTimerLockWaitTime, setTimerRunnableNeeded, shutdown, start, stopRunnables, unlockOwnedJobs

Methods inherited from class Object

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

Constructor Details

SpringAsyncHistoryExecutor

public SpringAsyncHistoryExecutor()

SpringAsyncHistoryExecutor

public SpringAsyncHistoryExecutor(AsyncJobExecutorConfiguration configuration)

Method Details

init

protected void init()

initializeJobEntityManager

protected void initializeJobEntityManager()

Overrides:

initializeJobEntityManager in class AbstractAsyncExecutor

createResetExpiredJobsRunnable

protected ResetExpiredJobsRunnable createResetExpiredJobsRunnable(String resetRunnableName)

Overrides:

createResetExpiredJobsRunnable in class DefaultAsyncJobExecutor