Package org.camunda.bpm.container.impl.threading.ra.inflow

Class JcaInflowExecuteJobsRunnable

java.lang.Object

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

org.camunda.bpm.container.impl.threading.ra.inflow.JcaInflowExecuteJobsRunnable

All Implemented Interfaces:

Runnable

public class JcaInflowExecuteJobsRunnable
extends ExecuteJobsRunnable

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected static Method	method
protected JcaExecutorServiceConnector	ra

Fields inherited from class org.camunda.bpm.engine.impl.jobexecutor.ExecuteJobsRunnable

jobExecutor, jobIds, processEngine

Constructor Summary

Constructors

Constructor	Description
JcaInflowExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine, JcaExecutorServiceConnector connector)

Method Summary

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)
protected void	loadMethod()
protected ClassLoader	switchClassLoader()	Context class loader switch is not necessary since the loader used for job execution is successor of the engine's

Methods inherited from class org.camunda.bpm.engine.impl.jobexecutor.ExecuteJobsRunnable

run, unlockJob

Methods inherited from class java.lang.Object

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

Field Detail

ra

protected final JcaExecutorServiceConnector ra

method

protected static Method method

Constructor Detail

JcaInflowExecuteJobsRunnable

public JcaInflowExecuteJobsRunnable(List<String> jobIds,
                                    ProcessEngineImpl processEngine,
                                    JcaExecutorServiceConnector connector)

Method Detail

executeJob

protected void executeJob(String nextJobId,
                          CommandExecutor commandExecutor,
                          JobFailureCollector jobFailureCollector)

Description copied from class: ExecuteJobsRunnable

Note: this is a hook to be overridden by org.camunda.bpm.container.impl.threading.ra.inflow.JcaInflowExecuteJobsRunnable.executeJob(String, CommandExecutor)

Overrides:

executeJob in class ExecuteJobsRunnable

loadMethod

protected void loadMethod()

switchClassLoader

protected ClassLoader switchClassLoader()

Context class loader switch is not necessary since the loader used for job execution is successor of the engine's

Overrides:

switchClassLoader in class ExecuteJobsRunnable

Returns:

the context class loader of the current thread.

See Also:

ExecuteJobsRunnable.switchClassLoader()