Class ExecuteJobsRunnable
- java.lang.Object
-
- org.camunda.bpm.engine.impl.jobexecutor.ExecuteJobsRunnable
-
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
JcaInflowExecuteJobsRunnable
public class ExecuteJobsRunnable extends Object implements Runnable
- Author:
- Tom Baeyens, Daniel Meyer
-
-
Field Summary
Fields Modifier and Type Field Description protected JobExecutor
jobExecutor
protected List<String>
jobIds
protected ProcessEngineImpl
processEngine
-
Constructor Summary
Constructors Constructor Description ExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
executeJob(String nextJobId, CommandExecutor commandExecutor, JobFailureCollector jobFailureCollector)
Note: this is a hook to be overridden by org.camunda.bpm.container.impl.threading.ra.inflow.JcaInflowExecuteJobsRunnable.executeJob(String, CommandExecutor)void
run()
protected ClassLoader
switchClassLoader()
Switch the context classloader to the ProcessEngine's to assure the loading of the engine classes during job execution
Note: this method is overridden by org.camunda.bpm.container.impl.threading.ra.inflow.JcaInflowExecuteJobsRunnable#switchClassLoader() - where the classloader switch is not requiredprotected void
unlockJob(String nextJobId, CommandExecutor commandExecutor)
-
-
-
Field Detail
-
jobExecutor
protected JobExecutor jobExecutor
-
processEngine
protected ProcessEngineImpl processEngine
-
-
Constructor Detail
-
ExecuteJobsRunnable
public ExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine)
-
-
Method Detail
-
executeJob
protected void executeJob(String nextJobId, CommandExecutor commandExecutor, JobFailureCollector jobFailureCollector)
Note: this is a hook to be overridden by org.camunda.bpm.container.impl.threading.ra.inflow.JcaInflowExecuteJobsRunnable.executeJob(String, CommandExecutor)
-
unlockJob
protected void unlockJob(String nextJobId, CommandExecutor commandExecutor)
-
switchClassLoader
protected ClassLoader switchClassLoader()
Switch the context classloader to the ProcessEngine's to assure the loading of the engine classes during job execution
Note: this method is overridden by org.camunda.bpm.container.impl.threading.ra.inflow.JcaInflowExecuteJobsRunnable#switchClassLoader() - where the classloader switch is not required- Returns:
- the classloader before the switch to return it back after the job execution
-
-