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

Class MessageBasedJobManagerConfigurator

  • All Implemented Interfaces:
    org.activiti.engine.cfg.ProcessEngineConfigurator, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle
    public class MessageBasedJobManagerConfigurator
extends java.lang.Object
implements org.activiti.engine.cfg.ProcessEngineConfigurator, org.springframework.context.SmartLifecycle

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static java.lang.String JOB_MESSAGE_HANDLER  

      • Fields inherited from interface org.springframework.context.SmartLifecycle

        DEFAULT_PHASE

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void beforeInit​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)
      Configures MessageBasedJobManager
      void configure​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)
      Configures input channel
      protected org.springframework.messaging.MessageHandler createJobMessageHandler​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)  
      protected MessageBasedJobManager createMessageBasedJobManager​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)  
      int getPriority()  
      boolean isRunning()  
      protected <T> T registerBean​(java.lang.String name, T bean)  
      void setContentType​(java.lang.String contentType)  
      void start()  
      void stop()  

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface org.springframework.context.SmartLifecycle

        getPhase, isAutoStartup, stop

    • Field Detail

      • JOB_MESSAGE_HANDLER

        public static final java.lang.String JOB_MESSAGE_HANDLER
        See Also:
        Constant Field Values

    • Constructor Detail

      • MessageBasedJobManagerConfigurator

        public MessageBasedJobManagerConfigurator​(org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory,
                                          org.springframework.cloud.stream.binding.BindingService bindingService,
                                          JobMessageInputChannelFactory inputChannelFactory,
                                          MessageBasedJobManagerFactory messageBasedJobManagerFactory,
                                          JobMessageHandlerFactory jobMessageHandlerFactory,
                                          org.springframework.cloud.stream.binder.ConsumerProperties consumerProperties)

    • Method Detail

      • createJobMessageHandler

        protected org.springframework.messaging.MessageHandler createJobMessageHandler​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)

      • createMessageBasedJobManager

        protected MessageBasedJobManager createMessageBasedJobManager​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)

      • beforeInit

        public void beforeInit​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)
        Configures MessageBasedJobManager
        Specified by:
        beforeInit in interface org.activiti.engine.cfg.ProcessEngineConfigurator

      • configure

        public void configure​(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)
        Configures input channel
        Specified by:
        configure in interface org.activiti.engine.cfg.ProcessEngineConfigurator

      • getPriority

        public int getPriority()
        Specified by:
        getPriority in interface org.activiti.engine.cfg.ProcessEngineConfigurator

      • start

        public void start()
        Specified by:
        start in interface org.springframework.context.Lifecycle

      • stop

        public void stop()
        Specified by:
        stop in interface org.springframework.context.Lifecycle

      • isRunning

        public boolean isRunning()
        Specified by:
        isRunning in interface org.springframework.context.Lifecycle

      • setContentType

        public void setContentType​(java.lang.String contentType)

      • registerBean

        protected <T> T registerBean​(java.lang.String name,
                             T bean)