Class 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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
    • 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