added durable and auto_delete options to exchange configuration

Author: Alessandro Chitolina

src/Child.php

@@ -75,7 +75,8 @@ public function run()
         $this->queue = new AmqpLibQueue($this->logger, $connection, $this->options['queue_name'], $this->eventDispatcher);
 
         if (!empty($this->options['exchange'])) {
-            $this->queue->setExchange($this->options['exchange']['name'], $this->options['exchange']['type']);
+            $ex_options = $this->options['exchange'];
+            $this->queue->setExchange($ex_options['name'], $ex_options['type'], $ex_options['durable'], $ex_options['auto_delete']);
         }
 
         $this->eventDispatcher->dispatch(Events::CHILD_START, new ChildStartEvent($this));

src/DependencyInjection/Configuration.php

@@ -98,6 +98,8 @@ private function addQueuesNode(NodeDefinition $root)
                                         ->end()
                                         ->defaultValue('fanout')
                                     ->end()
+                                    ->booleanNode('durable')->defaultTrue()->end()
+                                    ->booleanNode('auto_delete')->defaultFalse()->end()
                                 ->end()
                             ->end()
                             ->arrayNode('worker')

src/Queue/AmqpLibQueue.php

@@ -104,9 +104,9 @@ public function publishMessage($data)
         $this->channel->basic_publish($message, '', $this->queue);
     }
 
-    public function setExchange($name, $type)
+    public function setExchange($name, $type, $durable, $auto_delete)
     {
-        $this->channel->exchange_declare($name, $type);
+        $this->channel->exchange_declare($name, $type, $durable, $auto_delete);
         $this->channel->queue_bind($this->queue, $name);
     }
 

src/Queue/QueueInterface.php

@@ -6,7 +6,7 @@ interface QueueInterface
 {
     public function runLoop();
 
-    public function setExchange($name, $type);
+    public function setExchange($name, $type, $durable, $auto_delete);
 
     public function publishMessage($data);