public class SpringJobExecutor extends JobExecutor
This is a spring based implementation of the JobExecutor using spring
abstraction TaskExecutor 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.
acquireJobsCmd, acquireJobsRunnable, clockReader, commandExecutor, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxJobsPerAcquisition, name, rejectedJobsHandler, waitTimeInMillis| Constructor and Description |
|---|
SpringJobExecutor() |
SpringJobExecutor(org.springframework.core.task.TaskExecutor taskExecutor) |
| Modifier and Type | Method and Description |
|---|---|
void |
executeJobs(List<String> jobIds) |
org.springframework.core.task.TaskExecutor |
getTaskExecutor() |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Required spring injected
TaskExecutor implementation that will be
used to execute runnable jobs. |
protected void |
startExecutingJobs() |
protected void |
stopExecutingJobs() |
ensureCleanup, ensureInitialization, getAcquireJobsCmd, getAcquireJobsRunnable, getCommandExecutor, getCurrentTime, getLockOwner, getLockTimeInMillis, getMaxJobsPerAcquisition, getName, getRejectedJobsHandler, getWaitTimeInMillis, isActive, isAutoActivate, jobDone, jobDone, jobWasAdded, setAcquireJobsCmd, setAcquireJobsRunnable, setAutoActivate, setClockReader, setCommandExecutor, setLockOwner, setLockTimeInMillis, setMaxJobsPerAcquisition, setRejectedJobsHandler, setWaitTimeInMillis, shutdown, start, startJobAcquisitionThread, stopJobAcquisitionThreadpublic SpringJobExecutor()
public SpringJobExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
public org.springframework.core.task.TaskExecutor getTaskExecutor()
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
TaskExecutor implementation that will be
used to execute runnable jobs.taskExecutor - public void executeJobs(List<String> jobIds)
executeJobs in class JobExecutorprotected void startExecutingJobs()
startExecutingJobs in class JobExecutorprotected void stopExecutingJobs()
stopExecutingJobs in class JobExecutorCopyright © 2016 Alfresco. All rights reserved.