eMAGTechLabs / RabbitMqBundle

DependencyInjection/OldSoundRabbitMqExtension.php

Spacing +10 added lines, -10 removed lines

@@ -39,7 +39,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);
@@ -192,7 +192,7 @@ 
             $definition->addTag('old_sound_rabbit_mq.consumer');
             foreach ($consumer['groups'] as $group) {
                 $this->groups[] = $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'])) {
@@ -260,7 +260,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."
                 );
             }
@@ -281,7 +281,7 @@ 
 
             foreach ($consumer['groups'] as $group) {
                 $this->groups[] = $group;
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
             }
 
             if ($consumer['queues_provider']) {
@@ -348,7 +348,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."
                 );
             }
@@ -364,7 +364,7 @@ 
 
             foreach ($consumer['groups'] as $group) {
                 $this->groups[] = $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)) {
@@ -446,7 +446,7 @@ 
 
             foreach ($consumer['groups'] as $group) {
                 $this->groups[] = $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'])) {
@@ -502,7 +502,7 @@ 
 
             foreach ($anon['groups'] as $group) {
                 $this->groups[] = $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);
@@ -529,10 +529,10 @@ 
             ;
             $this->injectConnection($definition, $group['connection']);
             if ($this->collectorEnabled) {
-                $this->injectLoggedChannel($definition, $key . '_group_consumer', $group['connection']);
+                $this->injectLoggedChannel($definition, $key.'_group_consumer', $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(