Package org.activiti.services.connectors.conf

Class CloudConnectorsAutoConfiguration

java.lang.Object

org.activiti.services.connectors.conf.CloudConnectorsAutoConfiguration

@AutoConfiguration
@AutoConfigureBefore(org.activiti.runtime.api.conf.ConnectorsAutoConfiguration.class)
@PropertySource("classpath:config/integration-result-stream.properties")
@EnableRetry
public class CloudConnectorsAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
CloudConnectorsAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
IntegrationContextMessageBuilderFactory	integrationContextMessageBuilderFactory(RuntimeBundleProperties properties)
IntegrationRequestBuilder	integrationRequestBuilder(RuntimeBundleInfoAppender runtimeBundleInfoAppender, org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties)
IntegrationRequestReplayer	integrationRequestReplayer(org.activiti.engine.RuntimeService runtimeService, org.activiti.engine.ManagementService managementService, MQServiceTaskBehavior mqServiceTaskBehavior)
IntegrationRequestSender	integrationRequestSender(org.springframework.cloud.stream.function.StreamBridge streamBridge, IntegrationContextMessageBuilderFactory messageBuilderFactory)
org.activiti.runtime.api.connector.DefaultServiceTaskBehavior	localServiceTaskBehavior(org.springframework.context.ApplicationContext applicationContext, org.activiti.runtime.api.connector.IntegrationContextBuilder integrationContextBuilder, org.activiti.engine.impl.bpmn.behavior.VariablesPropagator variablesPropagator)
MQServiceTaskBehavior	mqServiceTaskBehavior(org.activiti.engine.impl.persistence.entity.integration.IntegrationContextManager integrationContextManager, org.activiti.runtime.api.connector.IntegrationContextBuilder integrationContextBuilder, org.activiti.runtime.api.connector.DefaultServiceTaskBehavior defaultServiceTaskBehavior, ProcessEngineEventsAggregator processEngineEventsAggregator, RuntimeBundleProperties runtimeBundleProperties, IntegrationRequestBuilder integrationRequestBuilder, IntegrationRequestSender integrationRequestSender)
Consumer<org.springframework.messaging.Message<IntegrationError>>	serviceTaskIntegrationErrorEventConsumer(ServiceTaskIntegrationErrorEventHandler handler)
ServiceTaskIntegrationErrorEventHandler	serviceTaskIntegrationErrorEventHandler(org.activiti.engine.RuntimeService runtimeService, org.activiti.engine.integration.IntegrationContextService integrationContextService, org.activiti.engine.ManagementService managementService, RuntimeBundleProperties runtimeBundleProperties, ProcessEngineEventsAggregator processEngineEventsAggregator)
Consumer<org.springframework.messaging.Message<IntegrationResult>>	serviceTaskIntegrationResultEventConsumer(ServiceTaskIntegrationResultEventHandler handler)
ServiceTaskIntegrationResultEventHandler	serviceTaskIntegrationResultEventHandler(org.activiti.engine.RuntimeService runtimeService, org.activiti.engine.integration.IntegrationContextService integrationContextService, RuntimeBundleProperties runtimeBundleProperties, org.activiti.engine.ManagementService managementService, ProcessEngineEventsAggregator processEngineEventsAggregator, org.activiti.engine.impl.bpmn.behavior.VariablesPropagator variablesPropagator)

Methods inherited from class java.lang.Object

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

Constructor Details

CloudConnectorsAutoConfiguration

public CloudConnectorsAutoConfiguration()

Method Details

serviceTaskIntegrationResultEventHandler

@Bean
@ConditionalOnMissingBean
public ServiceTaskIntegrationResultEventHandler serviceTaskIntegrationResultEventHandler(org.activiti.engine.RuntimeService runtimeService,
 org.activiti.engine.integration.IntegrationContextService integrationContextService,
 RuntimeBundleProperties runtimeBundleProperties,
 org.activiti.engine.ManagementService managementService,
 ProcessEngineEventsAggregator processEngineEventsAggregator,
 org.activiti.engine.impl.bpmn.behavior.VariablesPropagator variablesPropagator)

serviceTaskIntegrationResultEventConsumer

@Bean
public Consumer<org.springframework.messaging.Message<IntegrationResult>> serviceTaskIntegrationResultEventConsumer(ServiceTaskIntegrationResultEventHandler handler)

serviceTaskIntegrationErrorEventHandler

@Bean
@ConditionalOnMissingBean
public ServiceTaskIntegrationErrorEventHandler serviceTaskIntegrationErrorEventHandler(org.activiti.engine.RuntimeService runtimeService,
 org.activiti.engine.integration.IntegrationContextService integrationContextService,
 org.activiti.engine.ManagementService managementService,
 RuntimeBundleProperties runtimeBundleProperties,
 ProcessEngineEventsAggregator processEngineEventsAggregator)

serviceTaskIntegrationErrorEventConsumer

@Bean
public Consumer<org.springframework.messaging.Message<IntegrationError>> serviceTaskIntegrationErrorEventConsumer(ServiceTaskIntegrationErrorEventHandler handler)

integrationRequestSender

@Bean
@ConditionalOnMissingBean
public IntegrationRequestSender integrationRequestSender(org.springframework.cloud.stream.function.StreamBridge streamBridge,
 IntegrationContextMessageBuilderFactory messageBuilderFactory)

integrationRequestBuilder

@Bean
@ConditionalOnMissingBean
public IntegrationRequestBuilder integrationRequestBuilder(RuntimeBundleInfoAppender runtimeBundleInfoAppender,
 org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties)

integrationRequestReplayer

@Bean
@ConditionalOnMissingBean
public IntegrationRequestReplayer integrationRequestReplayer(org.activiti.engine.RuntimeService runtimeService,
 org.activiti.engine.ManagementService managementService,
 MQServiceTaskBehavior mqServiceTaskBehavior)

integrationContextMessageBuilderFactory

@Bean
@ConditionalOnMissingBean
public IntegrationContextMessageBuilderFactory integrationContextMessageBuilderFactory(RuntimeBundleProperties properties)

localServiceTaskBehavior

@Bean(name="localServiceTaskBehaviour")
@ConditionalOnMissingBean(name="localServiceTaskBehaviour")
public org.activiti.runtime.api.connector.DefaultServiceTaskBehavior localServiceTaskBehavior(org.springframework.context.ApplicationContext applicationContext,
 org.activiti.runtime.api.connector.IntegrationContextBuilder integrationContextBuilder,
 org.activiti.engine.impl.bpmn.behavior.VariablesPropagator variablesPropagator)

mqServiceTaskBehavior

@Bean(name="defaultServiceTaskBehavior")
@ConditionalOnMissingBean(name="defaultServiceTaskBehavior")
public MQServiceTaskBehavior mqServiceTaskBehavior(org.activiti.engine.impl.persistence.entity.integration.IntegrationContextManager integrationContextManager,
 org.activiti.runtime.api.connector.IntegrationContextBuilder integrationContextBuilder,
 org.activiti.runtime.api.connector.DefaultServiceTaskBehavior defaultServiceTaskBehavior,
 ProcessEngineEventsAggregator processEngineEventsAggregator,
 RuntimeBundleProperties runtimeBundleProperties,
 IntegrationRequestBuilder integrationRequestBuilder,
 IntegrationRequestSender integrationRequestSender)