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

Class MessageBasedJobManagerAutoConfiguration

java.lang.Object

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

@AutoConfiguration
@ConditionalOnProperty(name="spring.activiti.asyncExecutorActivate",
                       havingValue="true",
                       matchIfMissing=true)
@AutoConfigureAfter(org.activiti.cloud.common.messaging.config.ActivitiMessagingDestinationsAutoConfiguration.class)
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.function.StreamBridge streamBridge, 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.BindingServiceProperties bindingServiceProperties, JobMessageProducer jobMessageProducer)

Methods inherited from class java.lang.Object

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

Constructor Details

MessageBasedJobManagerAutoConfiguration

public MessageBasedJobManagerAutoConfiguration()

Method Details

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(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties,
 JobMessageProducer jobMessageProducer)

jobMessageProducer

@Bean
@ConditionalOnMissingBean
public JobMessageProducer jobMessageProducer(org.springframework.cloud.stream.function.StreamBridge streamBridge,
 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)