diff --git a/Transport/Connection.php b/Transport/Connection.php index b0c9fe4..3ea7784 100644 --- a/Transport/Connection.php +++ b/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);