Keep track of the declared queues inside RabbitMQ. So we won't check unnecessary times.

Author: adm-bome

src/Queue/RabbitMQQueue.php

@@ -399,12 +399,20 @@ public function deleteExchange(string $name, bool $unused = false): void
      */
     public function isQueueExists(string $name = null): bool
     {
+        $queueName = $this->getQueue($name);
+
+        if ($this->isQueueDeclared($queueName)) {
+            return true;
+        }
+
         try {
             // create a temporary channel, so the main channel will not be closed on exception
             $channel = $this->createChannel();
-            $channel->queue_declare($this->getQueue($name), true);
+            $channel->queue_declare($queueName, true);
             $channel->close();
 
+            $this->queues[] = $queueName;
+
             return true;
         } catch (AMQPProtocolChannelException $exception) {
             if ($exception->amqp_reply_code === 404) {
@@ -451,6 +459,9 @@ public function deleteQueue(string $name, bool $if_unused = false, bool $if_empt
             return;
         }
 
+        $idx = array_search($name, $this->queues);
+        unset($this->queues[$idx]);
+
         $this->getChannel()->queue_delete($name, $if_unused, $if_empty);
     }