bug #53944 [Messenger] Gracefully fallback to empty queue config (Wirone)

nicolas-grekas · nicolas-grekas · commit f44d074cdc4a · 2024-02-14T17:15:44.000+01:00
This PR was submitted for the 6.4 branch but it was merged into the 5.4 branch instead. Discussion ---------- [Messenger] Gracefully fallback to empty queue config | Q | A | ------------- | --- | Branch? | 5.4 | Bug fix? | yes | New feature? | no | Deprecations? | no | Issues | Fixes #53579 | License | MIT Do not produce notice/warning when consuming from multiple transports and explicitly listed queues. These queues might not be present on each consumed transport. Commits ------- 9d67850 Do not produce notice/warning when consuming from multiple transports and explicitly listed queues
diff --git a/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php b/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php
@@ -535,7 +535,7 @@ static function () {
     public function queue(string $queueName): \AMQPQueue
     {
         if (!isset($this->amqpQueues[$queueName])) {
-            $queueConfig = $this->queuesOptions[$queueName];
+            $queueConfig = $this->queuesOptions[$queueName] ?? [];
 
             $amqpQueue = $this->amqpFactory->createQueue($this->channel());
             $amqpQueue->setName($queueName);

Original file line number	Diff line number	Diff line change
`@@ -535,7 +535,7 @@ static function () {`
`535`	`535`	`public function queue(string $queueName): \AMQPQueue`
`536`	`536`	`{`
`537`	`537`	`if (!isset($this->amqpQueues[$queueName])) {`
`538`		`- $queueConfig = $this->queuesOptions[$queueName];`
	`538`	`+ $queueConfig = $this->queuesOptions[$queueName] ?? [];`
`539`	`539`
`540`	`540`	`$amqpQueue = $this->amqpFactory->createQueue($this->channel());`
`541`	`541`	`$amqpQueue->setName($queueName);`