diff --git a/backend/src/main/java/com/dragonguard/backend/domain/blockchain/messagequeue/BlockchainConsumer.java b/backend/src/main/java/com/dragonguard/backend/domain/blockchain/messagequeue/BlockchainConsumer.java index b7a4524a..a5403613 100644 --- a/backend/src/main/java/com/dragonguard/backend/domain/blockchain/messagequeue/BlockchainConsumer.java +++ b/backend/src/main/java/com/dragonguard/backend/domain/blockchain/messagequeue/BlockchainConsumer.java @@ -11,6 +11,7 @@ import org.springframework.context.event.EventListener; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import java.util.UUID; @@ -26,7 +27,7 @@ public class BlockchainConsumer implements EventConsumer { private final BlockchainService blockchainService; @Async - @Transactional + @Transactional(propagation = Propagation.REQUIRES_NEW) @EventListener @Override public void consume(final BlockchainEvent event) { diff --git a/backend/src/main/java/com/dragonguard/backend/domain/email/messagequeue/EventEmailConsumer.java b/backend/src/main/java/com/dragonguard/backend/domain/email/messagequeue/EventEmailConsumer.java index 64dbb1c8..279965f5 100644 --- a/backend/src/main/java/com/dragonguard/backend/domain/email/messagequeue/EventEmailConsumer.java +++ b/backend/src/main/java/com/dragonguard/backend/domain/email/messagequeue/EventEmailConsumer.java @@ -10,6 +10,7 @@ import org.springframework.context.event.EventListener; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import javax.mail.MessagingException; @@ -24,7 +25,7 @@ public class EventEmailConsumer implements EventConsumer { private final EmailSender emailSender; @Async - @Transactional + @Transactional(propagation = Propagation.REQUIRES_NEW) @EventListener @Override public void consume(final EmailEvent event) { diff --git a/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventGitRepoInfoConsumer.java b/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventGitRepoInfoConsumer.java index e1befe19..97310e2a 100644 --- a/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventGitRepoInfoConsumer.java +++ b/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventGitRepoInfoConsumer.java @@ -9,6 +9,7 @@ import org.springframework.context.event.EventListener; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; /** @@ -21,7 +22,7 @@ public class EventGitRepoInfoConsumer implements EventConsumer private final GitRepoMemberFacade gitRepoMemberFacade; @Async - @Transactional + @Transactional(propagation = Propagation.REQUIRES_NEW) @EventListener @Override public void consume(final GitRepoInfoEvent event) { diff --git a/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventSparkLineConsumer.java b/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventSparkLineConsumer.java index cbce35ce..0e0f96f2 100644 --- a/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventSparkLineConsumer.java +++ b/backend/src/main/java/com/dragonguard/backend/domain/gitrepo/messagequeue/EventSparkLineConsumer.java @@ -9,6 +9,7 @@ import org.springframework.context.event.EventListener; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; /** @@ -21,7 +22,7 @@ public class EventSparkLineConsumer implements EventConsumer { private final GitRepoService gitRepoService; @Async - @Transactional + @Transactional(propagation = Propagation.REQUIRES_NEW) @EventListener @Override public void consume(final SparkLineEvent sparkLineEvent) { diff --git a/backend/src/main/java/com/dragonguard/backend/domain/member/messagequeue/ContributionClientConsumer.java b/backend/src/main/java/com/dragonguard/backend/domain/member/messagequeue/ContributionClientConsumer.java index 1e06defc..64e8fd74 100644 --- a/backend/src/main/java/com/dragonguard/backend/domain/member/messagequeue/ContributionClientConsumer.java +++ b/backend/src/main/java/com/dragonguard/backend/domain/member/messagequeue/ContributionClientConsumer.java @@ -13,6 +13,7 @@ import org.springframework.context.event.EventListener; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; +import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; /** @@ -27,7 +28,7 @@ public class ContributionClientConsumer implements EventConsumer