Merge pull request vyuldashev#87 from PrivateDev/declare-queue-exchange-once

declare exchange & queue one time only

Author: vyuldashev

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

@@ -22,7 +22,10 @@ class RabbitMQQueue extends Queue implements QueueContract
     protected $channel;
 
     protected $declareExchange;
+    protected $declaredExchanges = [];
+
     protected $declareBindQueue;
+    protected $declaredBindQueue = [];
 
     protected $defaultQueue;
     protected $configQueue;
@@ -172,7 +175,8 @@ private function declareQueue($name)
         $name = $this->getQueueName($name);
         $exchange = $this->configExchange['name'] ?: $name;
 
-        if ($this->declareExchange) {
+        if ($this->declareExchange && ! in_array($exchange, $this->declaredExchanges)) {
+            $this->declaredExchanges[] = $exchange;
             // declare exchange
             $this->channel->exchange_declare(
                 $exchange,
@@ -183,7 +187,8 @@ private function declareQueue($name)
             );
         }
 
-        if ($this->declareBindQueue) {
+        if ($this->declareBindQueue && ! in_array($name, $this->declaredBindQueue)) {
+            $this->declaredBindQueue[] = $name;
             // declare queue
             $this->channel->queue_declare(
                 $name,