org.camunda.bpm.engine.impl.jobexecutor

Class RuntimeContainerJobExecutor

java.lang.Object

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

org.camunda.bpm.engine.impl.jobexecutor.RuntimeContainerJobExecutor

Direct Known Subclasses:

MscRuntimeContainerJobExecutor

public class RuntimeContainerJobExecutor
extends JobExecutor

JobExecutor implementation that delegates the execution of jobs to the RuntimeContainer

Author:

Daniel Meyer

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 and Description
RuntimeContainerJobExecutor()

Method Summary

Modifier and Type	Method and Description
void	executeJobs(List<String> jobIds, ProcessEngineImpl processEngine)
Runnable	getExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine)
protected RuntimeContainerDelegate	getRuntimeContainerDelegate()
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, 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

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeContainerJobExecutor

public RuntimeContainerJobExecutor()

Method Detail

startExecutingJobs

protected void startExecutingJobs()

Specified by:

startExecutingJobs in class JobExecutor

stopExecutingJobs

protected void stopExecutingJobs()

Specified by:

stopExecutingJobs in class JobExecutor

executeJobs

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

Specified by:

executeJobs in class JobExecutor

getRuntimeContainerDelegate

protected RuntimeContainerDelegate getRuntimeContainerDelegate()

getExecuteJobsRunnable

public Runnable getExecuteJobsRunnable(List<String> jobIds,
                                       ProcessEngineImpl processEngine)

Overrides:

getExecuteJobsRunnable in class JobExecutor