Merge pull request #658 from nathanjrobertson/producer_default_routing_key

Producer default routing key

Author: mihaileu

DependencyInjection/Configuration.php

@@ -124,6 +124,7 @@ protected function addProducers(ArrayNodeDefinition $node)
                             ->scalarNode('class')->defaultValue('%old_sound_rabbit_mq.producer.class%')->end()
                             ->scalarNode('enable_logger')->defaultFalse()->end()
                             ->scalarNode('service_alias')->defaultValue(null)->end()
+                            ->scalarNode('default_routing_key')->defaultValue('')->end()
                         ->end()
                     ->end()
                 ->end()

DependencyInjection/OldSoundRabbitMqExtension.php

@@ -185,6 +185,8 @@ protected function loadProducers()
                         ->registerAliasForArgument($producerServiceName, $producer['class'], $argName)
                         ->setPublic(false);
                 }
+
+                $definition->addMethodCall('setDefaultRoutingKey', array($producer['default_routing_key']));
             }
         } else {
             foreach ($this->config['producers'] as $key => $producer) {

RabbitMq/Producer.php

@@ -12,6 +12,7 @@ class Producer extends BaseAmqp implements ProducerInterface
 {
     protected $contentType = 'text/plain';
     protected $deliveryMode = 2;
+    protected $defaultRoutingKey = '';
 
     public function setContentType($contentType)
     {
@@ -27,6 +28,13 @@ public function setDeliveryMode($deliveryMode)
         return $this;
     }
 
+    public function setDefaultRoutingKey($defaultRoutingKey)
+    {
+        $this->defaultRoutingKey = $defaultRoutingKey;
+
+        return $this;
+    }
+
     protected function getBasicProperties()
     {
         return array('content_type' => $this->contentType, 'delivery_mode' => $this->deliveryMode);
@@ -40,7 +48,7 @@ protected function getBasicProperties()
      * @param array $additionalProperties
      * @param array $headers
      */
-    public function publish($msgBody, $routingKey = '', $additionalProperties = array(), array $headers = null)
+    public function publish($msgBody, $routingKey = null, $additionalProperties = array(), array $headers = null)
     {
         if ($this->autoSetupFabric) {
             $this->setupFabric();
@@ -53,7 +61,8 @@ public function publish($msgBody, $routingKey = '', $additionalProperties = arra
             $msg->set('application_headers', $headersTable);
         }
 
-        $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string)$routingKey);
+        $real_routingKey = $routingKey !== null ? $routingKey : $this->defaultRoutingKey;
+        $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string)$real_routingKey);
         $this->logger->debug('AMQP message published', array(
             'amqp' => array(
                 'body' => $msgBody,

Tests/DependencyInjection/OldSoundRabbitMqExtensionTest.php

@@ -313,6 +313,10 @@ public function testFooProducerDefinition()
                             'declare'     => false,
                         )
                     )
+                ),
+                array(
+                    'setDefaultRoutingKey',
+                    array('')
                 )
             ),
             $definition->getMethodCalls()
@@ -394,6 +398,10 @@ public function testDefaultProducerDefinition()
                             'declare'     => false,
                         )
                     )
+                ),
+                array(
+                    'setDefaultRoutingKey',
+                    array('')
                 )
             ),
             $definition->getMethodCalls()