Package org.camunda.bpm.quarkus.engine.extension.impl

Class ManagedJobExecutor

java.lang.Object

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

org.camunda.bpm.quarkus.engine.extension.impl.ManagedJobExecutor

public class ManagedJobExecutor
extends JobExecutor

A JobExecutor implementation that utilises a separate thread pool to acquire and execute jobs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ManagedJobExecutor.QuarkusClassLoaderExecuteJobsRunnable

Field Summary

Fields

Modifier and Type	Field	Description
protected ClassLoader	applicationClassLoader
protected org.eclipse.microprofile.context.ManagedExecutor	taskExecutor

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(org.eclipse.microprofile.context.ManagedExecutor taskExecutor)	Constructs a new ManagedJobExecutor with the provided ManagedExecutor instance.
ManagedJobExecutor(org.eclipse.microprofile.context.ManagedExecutor taskExecutor, ClassLoader applicationClassLoader)	Constructs a new ManagedJobExecutor with the provided ManagedExecutor instance and application classloader.

Method Summary

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

Field Details

taskExecutor

protected org.eclipse.microprofile.context.ManagedExecutor taskExecutor

applicationClassLoader

protected ClassLoader applicationClassLoader

Constructor Details

ManagedJobExecutor

public ManagedJobExecutor(org.eclipse.microprofile.context.ManagedExecutor taskExecutor)

Constructs a new ManagedJobExecutor with the provided ManagedExecutor instance.

ManagedJobExecutor

public ManagedJobExecutor(org.eclipse.microprofile.context.ManagedExecutor taskExecutor,
 ClassLoader applicationClassLoader)

Constructs a new ManagedJobExecutor with the provided ManagedExecutor instance and application classloader.

Method Details

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

getExecuteJobsRunnable

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

Overrides:

getExecuteJobsRunnable in class JobExecutor