Load bindings in config and extension

Author: fatmuemoo

DependencyInjection/Configuration.php

@@ -28,6 +28,7 @@ public function getConfigTreeBuilder()
         ;
 
         $this->addConnections($rootNode);
+        $this->addBindings($rootNode);
         $this->addProducers($rootNode);
         $this->addConsumers($rootNode);
         $this->addMultipleConsumers($rootNode);
@@ -71,6 +72,7 @@ protected function addConnections(ArrayNodeDefinition $node)
         ;
     }
 
+
     protected function addProducers(ArrayNodeDefinition $node)
     {
         $node
@@ -93,6 +95,30 @@ protected function addProducers(ArrayNodeDefinition $node)
         ;
     }
 
+    protected function addBindings(ArrayNodeDefinition $node)
+    {
+        $node
+            ->fixXmlConfig('binding')
+            ->children()
+                ->arrayNode('bindings')
+                    ->canBeUnset()
+                    ->prototype('array')
+                        ->children()
+                            ->scalarNode('connection')->defaultValue('default')->end()
+                            ->scalarNode('exchange')->defaultNull()->end()
+                            ->scalarNode('destination')->defaultNull()->end()
+                            ->scalarNode('routing_key')->defaultNull()->end()
+                            ->booleanNode('nowait')->defaultFalse()->end()
+                            ->booleanNode('destination_is_exchange')->defaultFalse()->end()
+                            ->variableNode('arguments')->defaultNull()->end()
+                            ->scalarNode('class')->defaultValue('%old_sound_rabbit_mq.binding.class%')->end()
+                        ->end()
+                    ->end()
+                ->end()
+            ->end()
+        ;
+    }
+
     protected function addConsumers(ArrayNodeDefinition $node)
     {
         $node

DependencyInjection/OldSoundRabbitMqExtension.php

@@ -46,6 +46,7 @@ public function load(array $configs, ContainerBuilder $container)
         $this->collectorEnabled = $this->config['enable_collector'];
 
         $this->loadConnections();
+        $this->loadBindings();
         $this->loadProducers();
         $this->loadConsumers();
         $this->loadMultipleConsumers();
@@ -96,6 +97,30 @@ protected function loadConnections()
         }
     }
 
+    protected function loadBindings()
+    {
+        if ($this->config['sandbox']) {
+            return;
+        }
+        foreach ($this->config['bindings'] as $binding) {
+            ksort($binding);
+            $definition = new Definition($binding['class']);
+            $definition->addTag('old_sound_rabbit_mq.binding');
+            $definition->addMethodCall('setExchange', array($binding['exchange']));
+            $definition->addMethodCall('setDestination', array($binding['destination']));
+            $definition->addMethodCall('setRoutingKey', array($binding['routing_key']));
+            $definition->addMethodCall('isNowait', array($binding['nowait']));
+            $definition->addMethodCall('setDestinationIsExchange', array($binding['destination_is_exchange']));
+            $this->injectConnection($definition, $binding['connection']);
+            $key = md5(json_encode($binding));
+            if ($this->collectorEnabled) {
+                // in the context of a binding, I don't thing logged channels are needed?
+                $this->injectLoggedChannel($definition, $key, $binding['connection']);
+            }
+            $this->container->setDefinition(sprintf('old_sound_rabbit_mq.%s_binding', $key), $definition);
+        }
+    }
+
     protected function loadProducers()
     {
         if ($this->config['sandbox'] == false) {

Resources/config/rabbitmq.xml

@@ -7,6 +7,7 @@
         <parameter key="old_sound_rabbit_mq.connection.class">PhpAmqpLib\Connection\AMQPConnection</parameter>
         <parameter key="old_sound_rabbit_mq.lazy.connection.class">PhpAmqpLib\Connection\AMQPLazyConnection</parameter>
         <parameter key="old_sound_rabbit_mq.connection_factory.class">OldSound\RabbitMqBundle\RabbitMq\AMQPConnectionFactory</parameter>
+        <parameter key="old_sound_rabbit_mq.binding.class">OldSound\RabbitMqBundle\RabbitMq\Binding</parameter>
         <parameter key="old_sound_rabbit_mq.producer.class">OldSound\RabbitMqBundle\RabbitMq\Producer</parameter>
         <parameter key="old_sound_rabbit_mq.consumer.class">OldSound\RabbitMqBundle\RabbitMq\Consumer</parameter>
         <parameter key="old_sound_rabbit_mq.multi_consumer.class">OldSound\RabbitMqBundle\RabbitMq\MultipleConsumer</parameter>

Tests/DependencyInjection/Fixtures/test.yml

@@ -138,7 +138,9 @@ old_sound_rabbit_mq:
                 type:           direct
             callback: bar.dynamic.callback
             queue_options_provider: bar.dynamic.provider
-            
+    bindings:
+        - {exchange: foo, destination: bar, routing_key: baz}
+        - {exchange: moo, connection: default2, destination: cow, nowait: true, destination_is_exchange: true, arguments: {moo:cow}}
     anon_consumers:
         foo_anon_consumer:
             connection:      foo_connection

Tests/DependencyInjection/OldSoundRabbitMqExtensionTest.php

@@ -113,6 +113,44 @@ public function testDefaultConnectionDefinition()
         $this->assertEquals('%old_sound_rabbit_mq.connection.class%', $definition->getClass());
     }
 
+    public function testFooBinding()
+    {
+        $container = $this->getContainer('test.yml');
+        $binding = array(
+            'arguments'                 => null,
+            'class'                     => '%old_sound_rabbit_mq.binding.class%',
+            'connection'                => 'default',
+            'exchange'                  => 'foo',
+            'destination'               => 'bar',
+            'destination_is_exchange'   => false,
+            'nowait'                    => false,
+            'routing_key'               => 'baz',
+        );
+        ksort($binding);
+        $key = md5(json_encode($binding));
+        $name = sprintf('old_sound_rabbit_mq.%s_binding', $key);
+        $this->assertTrue($container->has($name));
+    }
+
+    public function testMooBinding()
+    {
+        $container = $this->getContainer('test.yml');
+        $binding = array(
+            'arguments'                 => array('moo' => 'cow'),
+            'class'                     => '%old_sound_rabbit_mq.binding.class%',
+            'connection'                => 'default2',
+            'exchange'                  => 'moo',
+            'destination'               => 'cow',
+            'destination_is_exchange'   => true,
+            'nowait'                    => true,
+            'routing_key'               => null,
+        );
+        ksort($binding);
+        $key = md5(json_encode($binding));
+        $name = sprintf('old_sound_rabbit_mq.%s_binding', $key);
+        $this->assertTrue($container->has($name));
+    }
+
     public function testFooProducerDefinition()
     {
         $container = $this->getContainer('test.yml');