We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
nack
1 parent 1ae24df commit 6ed35b6Copy full SHA for 6ed35b6
src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php
@@ -13,6 +13,7 @@
13
14
use Symfony\Component\Messenger\Exception\InvalidArgumentException;
15
use Symfony\Component\Messenger\Exception\LogicException;
16
+use Symfony\Component\Messenger\Exception\TransportException;
17
18
/**
19
* An AMQP connection.
@@ -516,8 +517,8 @@ public function channel(): \AMQPChannel
516
517
static function (): bool {
518
return false;
519
},
- static function (): bool {
520
- return false;
+ static function () {
521
+ throw new TransportException('Message publication failed due to a negative acknowledgment (nack) from the broker.');
522
}
523
);
524
0 commit comments