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

Class MessageBasedJobManagerAutoConfiguration

java.lang.Object

org.activiti.cloud.services.job.executor.MessageBasedJobManagerAutoConfiguration

@Configuration
@ConditionalOnProperty(name="spring.activiti.asyncExecutorActivate",
                       havingValue="true",
                       matchIfMissing=true)
@PropertySource("classpath:config/job-executor-channel.properties")
public class MessageBasedJobManagerAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
MessageBasedJobManagerAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
org.springframework.cloud.stream.config.BindingProperties	jobExecutorBindingProperties()
JobMessageBuilderFactory	jobMessageBuilderFactory(RuntimeBundleProperties properties)
JobMessageHandlerFactory	jobMessageHandlerFactory()
JobMessageInputChannelFactory	jobMessageInputChannelFactory(org.springframework.cloud.stream.binding.SubscribableChannelBindingTargetFactory bindingTargetFactory, org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties, org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory)
JobMessageProducer	jobMessageProducer(org.springframework.cloud.stream.binding.BinderAwareChannelResolver resolver, org.springframework.context.ApplicationEventPublisher eventPublisher, JobMessageBuilderFactory jobMessageBuilderFactory)
MessageBasedJobManagerConfigurator	messageBasedJobManagerConfigurator(org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory, org.springframework.cloud.stream.binding.BindingService bindingService, JobMessageInputChannelFactory jobMessageInputChannelFactory, MessageBasedJobManagerFactory messageBasedJobManagerFactory, JobMessageHandlerFactory jobMessageHandlerFactory)
MessageBasedJobManagerFactory	messageBasedJobManagerFactory(org.springframework.cloud.stream.config.BindingProperties bindingProperties, JobMessageProducer jobMessageProducer)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageBasedJobManagerAutoConfiguration

public MessageBasedJobManagerAutoConfiguration()

Method Detail

jobExecutorBindingProperties

@Bean
@ConditionalOnMissingBean(name="jobExecutorBindingProperties")
@ConfigurationProperties(prefix="activiti.cloud.rb.job-executor")
public org.springframework.cloud.stream.config.BindingProperties jobExecutorBindingProperties()

jobMessageBuilderFactory

@Bean
@ConditionalOnMissingBean
public JobMessageBuilderFactory jobMessageBuilderFactory(RuntimeBundleProperties properties)

jobMessageInputChannelFactory

@Bean
@ConditionalOnMissingBean
public JobMessageInputChannelFactory jobMessageInputChannelFactory(org.springframework.cloud.stream.binding.SubscribableChannelBindingTargetFactory bindingTargetFactory,
                                                                   org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties,
                                                                   org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory)

messageBasedJobManagerFactory

@Bean
@ConditionalOnMissingBean
public MessageBasedJobManagerFactory messageBasedJobManagerFactory(@Qualifier("jobExecutorBindingProperties")
                                                                   org.springframework.cloud.stream.config.BindingProperties bindingProperties,
                                                                   JobMessageProducer jobMessageProducer)

jobMessageProducer

@Bean
@ConditionalOnMissingBean
public JobMessageProducer jobMessageProducer(org.springframework.cloud.stream.binding.BinderAwareChannelResolver resolver,
                                             org.springframework.context.ApplicationEventPublisher eventPublisher,
                                             JobMessageBuilderFactory jobMessageBuilderFactory)

jobMessageHandlerFactory

@Bean
@ConditionalOnMissingBean
public JobMessageHandlerFactory jobMessageHandlerFactory()

messageBasedJobManagerConfigurator

@Bean
@ConditionalOnMissingBean
public MessageBasedJobManagerConfigurator messageBasedJobManagerConfigurator(org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory,
                                                                             org.springframework.cloud.stream.binding.BindingService bindingService,
                                                                             JobMessageInputChannelFactory jobMessageInputChannelFactory,
                                                                             MessageBasedJobManagerFactory messageBasedJobManagerFactory,
                                                                             JobMessageHandlerFactory jobMessageHandlerFactory)