Add producer support for default_routing_key

Author: nathanjrobertson

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', $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,