From b89670fa9d7fe6877ce2f7f64f3ccabdae56a580 Mon Sep 17 00:00:00 2001 From: kvrushifa Date: Fri, 12 Jan 2024 15:22:42 +0100 Subject: [PATCH] [Messenger] [AMQP] Throw exception on `nack` callback --- Transport/Connection.php | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/Transport/Connection.php b/Transport/Connection.php index 0357575..8abb893 100644 --- a/Transport/Connection.php +++ b/Transport/Connection.php @@ -13,6 +13,7 @@ use Symfony\Component\Messenger\Exception\InvalidArgumentException; use Symfony\Component\Messenger\Exception\LogicException; +use Symfony\Component\Messenger\Exception\TransportException; /** * An AMQP connection. @@ -516,8 +517,8 @@ public function channel(): \AMQPChannel static function (): bool { return false; }, - static function (): bool { - return false; + static function () { + throw new TransportException('Message publication failed due to a negative acknowledgment (nack) from the broker.'); } ); }