Package org.activiti.services.connectors.channel

Class ServiceTaskIntegrationResultEventHandler

java.lang.Object

org.activiti.services.connectors.channel.ServiceTaskIntegrationResultEventHandler

public class ServiceTaskIntegrationResultEventHandler
extends Object

Constructor Summary

Constructors

Constructor

Description

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)

Method Summary

Modifier and Type	Method	Description
void	receive(IntegrationResult integrationResult)

Methods inherited from class java.lang.Object

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

Constructor Details

ServiceTaskIntegrationResultEventHandler

public 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)

Method Details

receive

@Retryable(value=org.activiti.engine.ActivitiOptimisticLockingException.class,
           maxAttemptsExpression="${activiti.cloud.integration.result.retry.max-attempts:3}",
           backoff=@Backoff(delayExpression="${activiti.cloud.integration.result.retry.backoff.delay:0}"))
@Transactional(propagation=REQUIRES_NEW)
public void receive(IntegrationResult integrationResult)