Fix push performance issue.

Author: Argyris Margaritis

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

@@ -18,6 +18,8 @@ class RabbitMQQueue extends Queue implements QueueInterface
 	protected $channel;
 
 	protected $defaultQueue;
+    protected $declaredQueues = [];
+    protected $declaredDelayedQueues = [];
 	protected $configQueue;
 	protected $configExchange;
 
@@ -138,11 +140,20 @@ public function getChannel()
 
 	/**
 	 * @param string $name
+     *
+     * @return string
 	 */
 	public function declareQueue($name)
 	{
 		$name = $this->getQueueName($name);
 
+        // if the current queue has been already declared, skip this
+        if (!in_array($name, $this->declaredQueues)) {
+            array_push($this->declaredQueues, $name);
+        } else {
+            return $name;
+        }
+
 		// declare queue
 		$this->channel->queue_declare(
 			$name,
@@ -163,6 +174,9 @@ public function declareQueue($name)
 
 		// bind queue to the exchange
 		$this->channel->queue_bind($name, $name, $name);
+
+		return $name;
+
 	}
 
 	/**
@@ -177,6 +191,13 @@ public function declareDelayedQueue($destination, $delay)
 		$destination = $this->getQueueName($destination);
 		$name = $this->getQueueName($destination) . '_deferred_' . $delay;
 
+        // if the current delayed queue has been already declared, skip this
+        if (!in_array($name, $this->declaredDelayedQueues)) {
+            array_push($this->declaredDelayedQueues, $name);
+        } else {
+            return $name;
+        }
+
 		// declare exchange
 		$this->channel->exchange_declare(
 			$name,