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)
public class MessageBasedJobManagerAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
MessageBasedJobManagerAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
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, org.springframework.cloud.stream.binder.ConsumerProperties messageJobConsumerProperties)
MessageBasedJobManagerFactory	messageBasedJobManagerFactory(RuntimeBundleProperties runtimeBundleProperties, JobMessageProducer jobMessageProducer)
org.springframework.cloud.stream.binder.ConsumerProperties	messageJobConsumerProperties()

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

messageJobConsumerProperties

@Bean
@ConditionalOnMissingBean(name="messageJobConsumerProperties")
@ConfigurationProperties(prefix="spring.activiti.cloud.rb.job-executor.message-job-consumer")
public org.springframework.cloud.stream.binder.ConsumerProperties messageJobConsumerProperties()

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(RuntimeBundleProperties runtimeBundleProperties,
                                                                   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,
                                                                             org.springframework.cloud.stream.binder.ConsumerProperties messageJobConsumerProperties)