diff --git a/activiti-cloud-runtime-bundle-service/activiti-cloud-services-runtime-bundle/activiti-cloud-services-connectors/src/main/java/org/activiti/services/connectors/channel/ServiceTaskIntegrationErrorEventHandler.java b/activiti-cloud-runtime-bundle-service/activiti-cloud-services-runtime-bundle/activiti-cloud-services-connectors/src/main/java/org/activiti/services/connectors/channel/ServiceTaskIntegrationErrorEventHandler.java index 3d34c296231..4a7ba50589e 100644 --- a/activiti-cloud-runtime-bundle-service/activiti-cloud-services-runtime-bundle/activiti-cloud-services-connectors/src/main/java/org/activiti/services/connectors/channel/ServiceTaskIntegrationErrorEventHandler.java +++ b/activiti-cloud-runtime-bundle-service/activiti-cloud-services-runtime-bundle/activiti-cloud-services-connectors/src/main/java/org/activiti/services/connectors/channel/ServiceTaskIntegrationErrorEventHandler.java @@ -16,8 +16,6 @@ package org.activiti.services.connectors.channel; -import static org.springframework.transaction.annotation.Propagation.REQUIRES_NEW; - import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; @@ -39,7 +37,6 @@ import org.slf4j.LoggerFactory; import org.springframework.retry.annotation.Backoff; import org.springframework.retry.annotation.Retryable; -import org.springframework.transaction.annotation.Transactional; public class ServiceTaskIntegrationErrorEventHandler { @@ -70,7 +67,6 @@ public ServiceTaskIntegrationErrorEventHandler( maxAttemptsExpression = "${activiti.cloud.integration.error.retry.max-attempts:3}", backoff = @Backoff(delayExpression = "${activiti.cloud.integration.error.retry.backoff.delay:0}") ) - @Transactional(propagation = REQUIRES_NEW) public void receive(IntegrationError integrationError) { IntegrationContext integrationContext = integrationError.getIntegrationContext(); IntegrationContextEntity integrationContextEntity = integrationContextService.findById(