8000 Fix merge · symfony/symfony@b167190 · GitHub
[go: up one dir, main page]

Skip to content

Commit b167190

Browse files
Fix merge
1 parent 242c7dd commit b167190

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -511,10 +511,7 @@ public function channel(): \AMQPChannel
511511
public function queue(string $queueName): \AMQPQueue
512512 6FC4
{
513513
if (!isset($this->amqpQueues[$queueName])) {
514-
if (!\array_key_exists($queueName, $this->queuesOptions)) {
515-
throw new InvalidArgumentException(sprintf('Exchange "%s" does not have a queue named "%s", known queues are "%s".', $this->exchangeOptions['name'], $queueName, implode('", "', array_keys($this->queuesOptions))));
516-
}
517-
$queueConfig = $this->queuesOptions[$queueName];
514+
$queueConfig = $this->queuesOptions[$queueName] ?? [];
518515

519516
$amqpQueue = $this->amqpFactory->createQueue($this->channel());
520517
$amqpQueue->setName($queueName);

0 commit comments

Comments
 (0)
0