public class ManagedJobExecutor extends JobExecutor
JobExecutor
implementation that utilises an application server's
managed thread pool to acquire and execute jobs.acquireJobsCmdFactory, acquireJobsRunnable, backoffDecreaseThreshold, backoffTimeInMillis, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxBackoff, maxJobsPerAcquisition, maxWait, name, processEngines, rejectedJobsHandler, waitIncreaseFactor, waitTimeInMillis
Constructor and Description |
---|
ManagedJobExecutor(javax.enterprise.concurrent.ManagedExecutorService managedExecutorService)
Constructs a new ManagedJobExecutor with the provided
ManagedExecutorService |
Modifier and Type | Method and Description |
---|---|
void |
executeJobs(List<String> jobIds,
ProcessEngineImpl processEngine) |
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 ManagedJobExecutor(javax.enterprise.concurrent.ManagedExecutorService managedExecutorService)
ManagedExecutorService
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 © 2022. All rights reserved.