Merge pull request #23 from NiR-/fix/exchange-arguments

Fix exchange arguments
BedrockStreaming · Oct 22, 2015 · e84a5a1 · e84a5a1
2 parents d3c68fa + 8da219a
commit e84a5a1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/src/AmqpBundle/DependencyInjection/Configuration.php b/src/AmqpBundle/DependencyInjection/Configuration.php
@@ -107,6 +107,7 @@ protected function addProducers(ArrayNodeDefinition $node)
                                     ->arrayNode('arguments')
                                         ->prototype('scalar')->end()
                                         ->defaultValue(array())
+                                        ->normalizeKeys(false)
                                     ->end()
 
                                     // binding

diff --git a/src/AmqpBundle/Factory/ProducerFactory.php b/src/AmqpBundle/Factory/ProducerFactory.php
@@ -94,6 +94,7 @@ public function get($class, $connexion, array $exchangeOptions, array $queueOpti
         $exchange = new $this->exchangeClass($channel);
         $exchange->setName($exchangeOptions['name']);
         $exchange->setType($exchangeOptions['type']);
+        $exchange->setArguments($exchangeOptions['arguments']);
         $exchange->setFlags(
             ($exchangeOptions['passive'] ? AMQP_PASSIVE : AMQP_NOPARAM) |
             ($exchangeOptions['durable'] ? AMQP_DURABLE : AMQP_NOPARAM) |

diff --git a/src/AmqpBundle/Tests/Units/Factory/ProducerFactory.php b/src/AmqpBundle/Tests/Units/Factory/ProducerFactory.php
@@ -75,7 +75,8 @@ public function testFactory()
                 'passive' => false,
                 'durable' => true,
                 'auto_delete' => false,
-                'routing_keys' => ['key']
+                'routing_keys' => ['key'],
+                'arguments' => ['alternate-exchange' => 'my-ae'],
             ])
             ->and($queueOptions = [
                 'name' => 'myqueue',