Package org.camunda.bpm.engine.impl.jobexecutor

Class ExecuteJobsRunnable

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.ExecuteJobsRunnable

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

JcaInflowExecuteJobsRunnable

public class ExecuteJobsRunnable
extends java.lang.Object
implements java.lang.Runnable

Author:

Tom Baeyens, Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected JobExecutor	jobExecutor
protected java.util.List<java.lang.String>	jobIds
protected ProcessEngineImpl	processEngine

Constructor Summary

Constructors

Constructor	Description
ExecuteJobsRunnable(java.util.List<java.lang.String> jobIds, ProcessEngineImpl processEngine)

Method Summary

Modifier and Type	Method	Description
protected void	executeJob(java.lang.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 java.lang.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
protected void	unlockJob(java.lang.String nextJobId, CommandExecutor commandExecutor)

Methods inherited from class java.lang.Object

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

Field Detail

jobIds

protected final java.util.List<java.lang.String> jobIds

jobExecutor

protected JobExecutor jobExecutor

processEngine

protected ProcessEngineImpl processEngine

Constructor Detail

ExecuteJobsRunnable

public ExecuteJobsRunnable(java.util.List<java.lang.String> jobIds,
                           ProcessEngineImpl processEngine)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

executeJob

protected void executeJob(java.lang.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(java.lang.String nextJobId,
                         CommandExecutor commandExecutor)

switchClassLoader

protected java.lang.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