declare exchange on queue if set in configuration

Author: Alessandro Chitolina

src/Child.php

@@ -69,6 +69,10 @@ public function run()
         $connection = $this->connectionManager->getConnection($this->options['connection']);
         $this->queue = new AmqpLibQueue($this->logger, $connection, $this->options['queue_name']);
 
+        if ($this->options['exchange']) {
+            $this->queue->setExchange($this->options['exchange']['name'], $this->options['exchange']['type']);
+        }
+
         $this->eventDispatcher->dispatch(Events::CHILD_START, new ChildStartEvent($this));
         $this->logger->info('Started. Waiting for jobs...');
 

src/Queue/AmqpLibQueue.php

@@ -104,6 +104,11 @@ public function processMessage(AMQPMessage $msg)
         $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
     }
 
+    public function setExchange($name, $type)
+    {
+        $this->channel->exchange_declare($name, $type);
+    }
+
     public function setSymfonyConsoleApp($console)
     {
         $this->symfony_app = $console;