Merge pull request #7 from dmitry-udod/master

Add routing_key support

Author: FractalizeR

README.md

@@ -34,7 +34,7 @@ In your ```config/queue.php``` file you have to provide the following:
         'password' => 'guest',
         'vhost' => '/',
         'queue' => null,
-        'queue_flags' => ['durable' => true], //Durable queue (survives server crash)
+        'queue_flags' => ['durable' => true, 'routing_key' => null], //Durable queue (survives server crash)
         'message_properties' => ['delivery_mode' => 2], //Persistent messages (survives server crash)
         'channel_id' => null,
         'exchange_name' => null,

src/Queue/AMQPQueue.php

@@ -110,7 +110,7 @@ public function push($job, $data = '', $queue = null)
         $queue = $this->getQueueName($queue);
         $this->declareQueue($queue);
         $payload = new AMQPMessage($this->createPayload($job, $data), $this->messageProperties);
-        $this->channel->basic_publish($payload, $this->exchangeName, $queue);
+        $this->channel->basic_publish($payload, $this->exchangeName, $this->getRoutingKey($queue));
         return true;
     }
 
@@ -280,6 +280,17 @@ protected function getQueueName($name)
         return $name;
     }
 
+    /**
+     *  Get routing key from config or use default one (queue name)
+     *
+     * @param $queue string
+     * @return string Routing key name
+     */
+    protected function getRoutingKey($queue)
+    {
+        return empty($this->queueFlags['routing_key']) ? $queue : $this->queueFlags['routing_key'];
+    }
+
     /**
      * @param string      $queueName
      * @param null|string $deferredQueueName