From 68565de8b4a437bc71f68861a53496d4d63a79a8 Mon Sep 17 00:00:00 2001 From: "cristian.almohalla" Date: Tue, 15 Jun 2021 15:25:05 +0200 Subject: [PATCH] fix next handle on query --- src/SymfonyMessenger/TransactionMiddleware.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/SymfonyMessenger/TransactionMiddleware.php b/src/SymfonyMessenger/TransactionMiddleware.php index 531e2b5..a7055f8 100644 --- a/src/SymfonyMessenger/TransactionMiddleware.php +++ b/src/SymfonyMessenger/TransactionMiddleware.php @@ -21,7 +21,7 @@ public function __construct(TransactionalConnection $connection) public function handle(Envelope $envelope, StackInterface $stack): Envelope { if (\is_subclass_of($envelope->getMessage(), Query::class)) { - return $envelope; + return $stack->next()->handle($envelope, $stack); } try {