public class SpringJobExecutor extends JobExecutor
This is a spring based implementation of the JobExecutor
using spring abstraction TaskExecutor
for performing background task execution.
The idea behind this implementation is to externalize the configuration of the task executor, so it can leverage to Application servers controller thread pools, for example using the commonj API. The use of unmanaged thread in application servers is discouraged by the Java EE spec.
acquireJobsCmdFactory, acquireJobsRunnable, backoffDecreaseThreshold, backoffTimeInMillis, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxBackoff, maxJobsPerAcquisition, maxWait, name, processEngines, rejectedJobsHandler, waitIncreaseFactor, waitTimeInMillis
Constructor and Description |
---|
SpringJobExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
executeJobs(List<String> jobIds,
ProcessEngineImpl processEngine) |
org.springframework.core.task.TaskExecutor |
getTaskExecutor() |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Required spring injected
TaskExecutor } implementation that will be used to execute runnable jobs. |
protected void |
startExecutingJobs() |
protected void |
stopExecutingJobs() |
engineIterator, ensureCleanup, ensureInitialization, executeJobs, getAcquireJobsCmd, getAcquireJobsCmdFactory, getAcquireJobsRunnable, getBackoffDecreaseThreshold, getBackoffTimeInMillis, getCommandExecutor, getExecuteJobsRunnable, getLockOwner, getLockTimeInMillis, getMaxBackoff, getMaxJobsPerAcquisition, getMaxWait, getName, getProcessEngines, getRejectedJobsHandler, getWaitIncreaseFactor, getWaitTimeInMillis, hasRegisteredEngine, isActive, isAutoActivate, jobWasAdded, logAcquiredJobs, logAcquisitionAttempt, logAcquisitionFailureJobs, logRejectedExecution, registerProcessEngine, setAcquireJobsCmdFactory, setAutoActivate, setBackoffDecreaseThreshold, setBackoffTimeInMillis, setCommandExecutor, setLockOwner, setLockTimeInMillis, setMaxBackoff, setMaxJobsPerAcquisition, setMaxWait, setProcessEngines, setRejectedJobsHandler, setWaitIncreaseFactor, setWaitTimeInMillis, shutdown, start, startJobAcquisitionThread, stopJobAcquisitionThread, unregisterProcessEngine
public org.springframework.core.task.TaskExecutor getTaskExecutor()
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
TaskExecutor
} implementation that will be used to execute runnable jobs.taskExecutor
- public void executeJobs(List<String> jobIds, ProcessEngineImpl processEngine)
executeJobs
in class JobExecutor
protected void startExecutingJobs()
startExecutingJobs
in class JobExecutor
protected void stopExecutingJobs()
stopExecutingJobs
in class JobExecutor
Copyright © 2017. All rights reserved.