Queue name is a required parameter

symfony · May 8, 2020 · 9d48eed · 9d48eed
1 parent a609375
commit 9d48eed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php b/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
@@ -326,7 +326,7 @@ public function get(string $queueName): ?\AMQPEnvelope
                 // If we get a 404 for the queue, it means we need to set up the exchange & queue.
                 $this->setupExchangeAndQueues();
 
-                return $this->get();
+                return $this->get($queueName);
             }
 
             throw $e;