Package org.camunda.bpm.engine.cdi.impl

Class ManagedJobExecutor

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.JobExecutor

org.camunda.bpm.engine.cdi.impl.ManagedJobExecutor

public class ManagedJobExecutor
extends JobExecutor

JobExecutor implementation that utilises an application server's managed thread pool to acquire and execute jobs.

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
ManagedJobExecutor(jakarta.enterprise.concurrent.ManagedExecutorService managedExecutorService)	Constructs a new ManagedJobExecutor with the provided ManagedExecutorService

Method Summary

Modifier and Type	Method	Description
void	executeJobs(List<String> jobIds, ProcessEngineImpl processEngine)
protected void	startExecutingJobs()
protected void	stopExecutingJobs()

Methods inherited from class org.camunda.bpm.engine.impl.jobexecutor.JobExecutor

calculateTotalQueueCapacity, 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, logJobExecutionInfo, logRejectedExecution, registerProcessEngine, setAcquireJobsCmdFactory, setAutoActivate, setBackoffDecreaseThreshold, setBackoffTimeInMillis, setCommandExecutor, setLockOwner, setLockTimeInMillis, setMaxBackoff, setMaxJobsPerAcquisition, setMaxWait, setProcessEngines, setRejectedJobsHandler, setWaitIncreaseFactor, setWaitTimeInMillis, shutdown, start, startJobAcquisitionThread, stopJobAcquisitionThread, unregisterProcessEngine

Methods inherited from class java.lang.Object

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

Constructor Details

ManagedJobExecutor

public ManagedJobExecutor(jakarta.enterprise.concurrent.ManagedExecutorService managedExecutorService)

Constructs a new ManagedJobExecutor with the provided ManagedExecutorService

Method Details

executeJobs

public void executeJobs(List<String> jobIds,
 ProcessEngineImpl processEngine)

Specified by:

executeJobs in class JobExecutor

startExecutingJobs

protected void startExecutingJobs()

Specified by:

startExecutingJobs in class JobExecutor

stopExecutingJobs

protected void stopExecutingJobs()

Specified by:

stopExecutingJobs in class JobExecutor