Skip to content

Commit b89670f

Browse files
kvrushifanicolas-grekas
authored andcommitted
[Messenger] [AMQP] Throw exception on nack callback
1 parent 8ba6a2c commit b89670f

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

Transport/Connection.php

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313

1414
use Symfony\Component\Messenger\Exception\InvalidArgumentException;
1515
use Symfony\Component\Messenger\Exception\LogicException;
16+
use Symfony\Component\Messenger\Exception\TransportException;
1617

1718
/**
1819
* An AMQP connection.
@@ -516,8 +517,8 @@ public function channel(): \AMQPChannel
516517
static function (): bool {
517518
return false;
518519
},
519-
static function (): bool {
520-
return false;
520+
static function () {
521+
throw new TransportException('Message publication failed due to a negative acknowledgment (nack) from the broker.');
521522
}
522523
);
523524
}

0 commit comments

Comments
 (0)