Package org.activiti.cloud.services.job.executor

Class MessageBasedJobManager

  • All Implemented Interfaces:
    org.activiti.engine.impl.asyncexecutor.JobManager
    public class MessageBasedJobManager
extends org.activiti.engine.impl.asyncexecutor.DefaultJobManager

    • Field Summary

      • Fields inherited from class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

        processEngineConfiguration

    • Constructor Summary

      Constructors 
      Constructor Description
      MessageBasedJobManager​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl processEngineConfiguration, org.activiti.cloud.services.events.configuration.RuntimeBundleProperties runtimeBundleProperties, JobMessageProducer jobMessageProducer)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.String getDestination()
      Scoped destination name by runtime bundle service name
      java.lang.String getInputChannelName()  
      void sendMessage​(org.activiti.engine.runtime.Job job)  
      void setInputChannelName​(java.lang.String inputChannelName)  
      protected void triggerExecutorIfNeeded​(org.activiti.engine.impl.persistence.entity.JobEntity jobEntity)  
      void unacquire​(org.activiti.engine.runtime.Job job)  

      • Methods inherited from class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

        activateSuspendedJob, calculateMaxIterationsValue, copyJobInfo, createAsyncJob, createDeadLetterJobFromOtherJob, createExecutableJobFromOtherJob, createSuspendedJobFromOtherJob, createTimerJob, createTimerJobFromOtherJob, execute, executeJobHandler, executeMessageJob, executeTimerJob, fillDefaultAsyncJobInfo, getAsyncExecutor, getBusinessCalendarName, getCommandContext, getExecutionEntityManager, getMaxIterations, getProcessEngineConfiguration, hintAsyncExecutor, internalCreateAsyncJob, internalCreateLockedAsyncJob, isAsyncExecutorActive, isValidTime, moveDeadLetterJobToExecutableJob, moveJobToDeadLetterJob, moveJobToSuspendedJob, moveJobToTimerJob, moveTimerJobToExecutableJob, restoreExtraData, scheduleAsyncJob, scheduleTimerJob, setProcessEngineConfiguration

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • MessageBasedJobManager

        public MessageBasedJobManager​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl processEngineConfiguration,
                              org.activiti.cloud.services.events.configuration.RuntimeBundleProperties runtimeBundleProperties,
                              JobMessageProducer jobMessageProducer)

    • Method Detail

      • triggerExecutorIfNeeded

        protected void triggerExecutorIfNeeded​(org.activiti.engine.impl.persistence.entity.JobEntity jobEntity)
        Overrides:
        triggerExecutorIfNeeded in class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

      • unacquire

        public void unacquire​(org.activiti.engine.runtime.Job job)
        Specified by:
        unacquire in interface org.activiti.engine.impl.asyncexecutor.JobManager
        Overrides:
        unacquire in class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

      • getDestination

        public java.lang.String getDestination()
        Scoped destination name by runtime bundle service name

      • getInputChannelName

        public java.lang.String getInputChannelName()

      • setInputChannelName

        public void setInputChannelName​(java.lang.String inputChannelName)

      • sendMessage

        public void sendMessage​(org.activiti.engine.runtime.Job job)