Class SpringJobExecutor
- java.lang.Object
-
- org.camunda.bpm.engine.impl.jobexecutor.JobExecutor
-
- org.camunda.bpm.engine.spring.components.jobexecutor.SpringJobExecutor
-
public class SpringJobExecutor extends JobExecutor
This is a spring based implementation of the
JobExecutor
using spring abstractionTaskExecutor
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.
- Author:
- Pablo Ganga
-
-
Field Summary
-
Fields inherited from class org.camunda.bpm.engine.impl.jobexecutor.JobExecutor
acquireJobsCmdFactory, acquireJobsRunnable, backoffDecreaseThreshold, backoffTimeInMillis, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxBackoff, maxJobsPerAcquisition, maxWait, name, processEngines, rejectedJobsHandler, waitIncreaseFactor, waitTimeInMillis
-
-
Constructor Summary
Constructors Constructor Description SpringJobExecutor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
executeJobs(java.util.List<java.lang.String> jobIds, ProcessEngineImpl processEngine)
org.springframework.core.task.TaskExecutor
getTaskExecutor()
void
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Required spring injectedTaskExecutor
} implementation that will be used to execute runnable jobs.protected void
startExecutingJobs()
protected void
stopExecutingJobs()
-
Methods inherited from class org.camunda.bpm.engine.impl.jobexecutor.JobExecutor
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
-
-
-
-
Method Detail
-
getTaskExecutor
public org.springframework.core.task.TaskExecutor getTaskExecutor()
-
setTaskExecutor
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Required spring injectedTaskExecutor
} implementation that will be used to execute runnable jobs.- Parameters:
taskExecutor
-
-
executeJobs
public void executeJobs(java.util.List<java.lang.String> jobIds, ProcessEngineImpl processEngine)
- Specified by:
executeJobs
in classJobExecutor
-
startExecutingJobs
protected void startExecutingJobs()
- Specified by:
startExecutingJobs
in classJobExecutor
-
stopExecutingJobs
protected void stopExecutingJobs()
- Specified by:
stopExecutingJobs
in classJobExecutor
-
-