Package org.flowable.spring.job.service

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 org.flowable.job.service.impl.asyncexecutor.AbstractAsyncExecutor

AbstractAsyncExecutor.AcquireAsyncJobsDueRunnableConfiguration, AbstractAsyncExecutor.AcquireTimerRunnableConfiguration

Field Summary

Fields inherited from class org.flowable.spring.job.service.SpringAsyncExecutor

rejectedJobsHandler

Fields inherited from class org.flowable.job.service.impl.asyncexecutor.DefaultAsyncJobExecutor

asyncJobAcquisitionThread, resetExpiredJobThread, shutdownTaskExecutor, taskExecutor, timerJobAcquisitionThread

Fields inherited from class org.flowable.job.service.impl.asyncexecutor.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 org.flowable.spring.job.service.SpringAsyncExecutor

executeAsyncJob, getRejectedJobsHandler, initAsyncJobExecutionThreadPool, setRejectedJobsHandler

Methods inherited from class org.flowable.job.service.impl.asyncexecutor.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 org.flowable.job.service.impl.asyncexecutor.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 java.lang.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