diff --git a/Transport/Connection.php b/Transport/Connection.php index fc5e5d0..b399026 100644 --- a/Transport/Connection.php +++ b/Transport/Connection.php @@ -510,7 +510,7 @@ public function channel(): \AMQPChannel 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);