Skip to content

Commit c1781bd

Browse files
Merge branch '5.4' into 6.3
* 5.4: [Translation] Fix `TranslationNodeVisitor` with constant domain [Messenger] [AMQP] Throw exception on `nack` callback [Validator] revise Latvian translations [ErrorHandler] Fix `RecursiveDirectoryIterator` exception with wrong composer autoload [HttpFoundation] Request without content-type or content-length header should result in null values, not empty strings [Cache] Fix possible infinite loop in `CachePoolPass` [Mime] Fix undefined array key 0 when empty sender [Console] Allow '0' as a $shortcut in InputOption.php fix multi-byte code area to convert [Validator] Make it explicit when English translation differs from its resource name
2 parents faffa89 + f5ffb4c commit c1781bd

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

Transport/Connection.php

Lines changed: 2 additions & 1 deletion
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.
@@ -493,7 +494,7 @@ public function channel(): \AMQPChannel
493494
$this->amqpChannel->confirmSelect();
494495
$this->amqpChannel->setConfirmCallback(
495496
static fn (): bool => false,
496-
static fn (): bool => false
497+
static fn () => throw new TransportException('Message publication failed due to a negative acknowledgment (nack) from the broker.'),
497498
);
498499
}
499500

0 commit comments

Comments
 (0)