Skip to content

Commit

Permalink
Fix IntegrationError handler (#1146)
Browse files Browse the repository at this point in the history
* prevent rollback on error propagation

* fix arguments

* Revert "fix arguments"

This reverts commit 8ca5da9.

* Revert "prevent rollback on error propagation"

This reverts commit c9c4809.

* replace transactional with transactionTemplate

* fix test

* fix config

* Revert "fix config"

This reverts commit cac4f90.

* Revert "fix test"

This reverts commit 5da448a.

* Revert "replace transactional with transactionTemplate"

This reverts commit 8e6861f.

* remove transactional
  • Loading branch information
LorenzoDiGiuseppe authored Jul 6, 2023
1 parent 94ff914 commit ffdba70
Showing 1 changed file with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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 {

Expand Down Expand Up @@ -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(
Expand Down

0 comments on commit ffdba70

Please sign in to comment.