eMAGTechLabs / RabbitMqBundle

DependencyInjection/OldSoundRabbitMqExtension.php

Spacing +9 added lines, -9 removed lines

@@ -38,7 +38,7 @@ 
     {
         $this->container = $container;
 
-        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__ . '/../Resources/config')));
+        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__.'/../Resources/config')));
         $loader->load('rabbitmq.xml');
 
         $configuration = $this->getConfiguration($configs, $container);
@@ -190,7 +190,7 @@ 
             $definition->addTag('old_sound_rabbit_mq.base_amqp');
             $definition->addTag('old_sound_rabbit_mq.consumer');
             foreach ($consumer['groups'] as $group) {
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
             }
             //this consumer doesn't define an exchange -> using AMQP Default
             if (!isset($consumer['exchange_options'])) {
@@ -255,7 +255,7 @@ 
 
             if (empty($consumer['queues']) && empty($consumer['queues_provider'])) {
                 throw new InvalidConfigurationException(
-                    "Error on loading $key multiple consumer. " .
+                    "Error on loading $key multiple consumer. ".
                     "Either 'queues' or 'queues_provider' parameters should be defined."
                 );
             }
@@ -275,7 +275,7 @@ 
                 ->addMethodCall('setQueues', array($this->normalizeArgumentKeys($queues)));
 
             foreach ($consumer['groups'] as $group) {
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
             }
 
             if ($consumer['queues_provider']) {
@@ -339,7 +339,7 @@ 
 
             if (empty($consumer['queue_options_provider'])) {
                 throw new InvalidConfigurationException(
-                    "Error on loading $key dynamic consumer. " .
+                    "Error on loading $key dynamic consumer. ".
                     "'queue_provider' parameter should be defined."
                 );
             }
@@ -354,7 +354,7 @@ 
                 ->addMethodCall('setCallback', array(array(new Reference($consumer['callback']), 'execute')));
 
             foreach ($consumer['groups'] as $group) {
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
             }
 
             if (array_key_exists('qos_options', $consumer)) {
@@ -432,7 +432,7 @@ 
             ;
 
             foreach ($consumer['groups'] as $group) {
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
             }
 
             if (isset($consumer['idle_timeout_exit_code'])) {
@@ -487,7 +487,7 @@ 
             }
 
             foreach ($consumer['groups'] as $group) {
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
             }
 
             $name = sprintf('old_sound_rabbit_mq.%s_anon', $key);
@@ -510,7 +510,7 @@ 
                 $this->injectLoggedChannel($definition, $key, $group['connection']);
             }
 
-            $definition->addMethodCall('addConsumers', [new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.' . $key)]);
+            $definition->addMethodCall('addConsumers', [new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.'.$key)]);
 
             if (array_key_exists('qos_options', $group)) {
                 $definition->addMethodCall('setQosOptions', array(