Added messenger stamp NoTransactionStamp

68publishers · Nov 1, 2023 · b465696 · b465696
1 parent 82f77f9
commit b465696
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 3 deletions.
diff --git a/src/ArchitectureBundle/Bridge/Symfony/Messenger/Middleware/StoreTransactionMiddleware.php b/src/ArchitectureBundle/Bridge/Symfony/Messenger/Middleware/StoreTransactionMiddleware.php
@@ -4,6 +4,7 @@
 
 namespace SixtyEightPublishers\ArchitectureBundle\Bridge\Symfony\Messenger\Middleware;
 
+use SixtyEightPublishers\ArchitectureBundle\Bridge\Symfony\Messenger\Stamp\NoTransactionStamp;
 use SixtyEightPublishers\ArchitectureBundle\Infrastructure\Common\PersistenceAdapter\PersistenceAdapterInterface;
 use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\Exception\HandlerFailedException;
@@ -23,20 +24,22 @@ public function __construct(
      */
     public function handle(Envelope $envelope, StackInterface $stack): Envelope
     {
-        if ($this->persistenceAdapter->supportsTransactions()) {
+        $transactionsEnabled = null === $envelope->last(NoTransactionStamp::class);
+
+        if ($transactionsEnabled && $this->persistenceAdapter->supportsTransactions()) {
             $this->persistenceAdapter->beginTransaction();
         }
 
         try {
             $envelope = $stack->next()->handle($envelope, $stack);
 
-            if ($this->persistenceAdapter->supportsTransactions()) {
+            if ($transactionsEnabled && $this->persistenceAdapter->supportsTransactions()) {
                 $this->persistenceAdapter->commitTransaction();
             }
 
             return $envelope;
         } catch (Throwable $exception) {
-            if ($this->persistenceAdapter->supportsTransactions()) {
+            if ($transactionsEnabled && $this->persistenceAdapter->supportsTransactions()) {
                 $this->persistenceAdapter->rollbackTransaction();
             }
 

diff --git a/src/ArchitectureBundle/Bridge/Symfony/Messenger/Stamp/NoTransactionStamp.php b/src/ArchitectureBundle/Bridge/Symfony/Messenger/Stamp/NoTransactionStamp.php
@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace SixtyEightPublishers\ArchitectureBundle\Bridge\Symfony\Messenger\Stamp;
+
+use Symfony\Component\Messenger\Stamp\StampInterface;
+
+final class NoTransactionStamp implements StampInterface
+{
+}