View GitHub Repository RabbitMqBundle

Schedule Inspection
Subscribe
Test Failed
Pull Request — master (#38)
by Aleksandr
07:22
created
Status
Category
Toggle Patches
DependencyInjection/OldSoundRabbitMqExtension.php 1 patch
Spacing   +9 added lines, -9 removed lines patch added patch discarded remove patch 
@@ -38,7 +38,7 @@  discard block
 
 block discarded – undo
38 38 
     {
39 39 
         $this->container = $container;
40 40
41 
-        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__ . '/../Resources/config')));
41 
+        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__.'/../Resources/config')));
42 42 
         $loader->load('rabbitmq.xml');
43 43
44 44 
         $configuration = $this->getConfiguration($configs, $container);
 
@@ -190,7 +190,7 @@  discard block
 
 block discarded – undo
190 190 
             $definition->addTag('old_sound_rabbit_mq.base_amqp');
191 191 
             $definition->addTag('old_sound_rabbit_mq.consumer');
192 192 
             foreach ($consumer['groups'] as $group) {
193 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
193 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
194 194 
             }
195 195 
             //this consumer doesn't define an exchange -> using AMQP Default
196 196 
             if (!isset($consumer['exchange_options'])) {
 
@@ -258,7 +258,7 @@  discard block
 
 block discarded – undo
258 258
259 259 
             if (empty($consumer['queues']) && empty($consumer['queues_provider'])) {
260 260 
                 throw new InvalidConfigurationException(
261 
-                    "Error on loading $key multiple consumer. " .
261 
+                    "Error on loading $key multiple consumer. ".
262 262 
                     "Either 'queues' or 'queues_provider' parameters should be defined."
263 263 
                 );
264 264 
             }
 
@@ -278,7 +278,7 @@  discard block
 
 block discarded – undo
278 278 
                 ->addMethodCall('setQueues', array($this->normalizeArgumentKeys($queues)));
279 279
280 280 
             foreach ($consumer['groups'] as $group) {
281 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
281 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
282 282 
             }
283 283
284 284 
             if ($consumer['queues_provider']) {
 
@@ -345,7 +345,7 @@  discard block
 
 block discarded – undo
345 345
346 346 
             if (empty($consumer['queue_options_provider'])) {
347 347 
                 throw new InvalidConfigurationException(
348 
-                    "Error on loading $key dynamic consumer. " .
348 
+                    "Error on loading $key dynamic consumer. ".
349 349 
                     "'queue_provider' parameter should be defined."
350 350 
                 );
351 351 
             }
 
@@ -360,7 +360,7 @@  discard block
 
 block discarded – undo
360 360 
                 ->addMethodCall('setCallback', array(array(new Reference($consumer['callback']), 'execute')));
361 361
362 362 
             foreach ($consumer['groups'] as $group) {
363 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
363 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
364 364 
             }
365 365
366 366 
             if (array_key_exists('qos_options', $consumer)) {
 
@@ -441,7 +441,7 @@  discard block
 
 block discarded – undo
441 441 
             ;
442 442
443 443 
             foreach ($consumer['groups'] as $group) {
444 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
444 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
445 445 
             }
446 446
447 447 
             if (isset($consumer['idle_timeout_exit_code'])) {
 
@@ -496,7 +496,7 @@  discard block
 
 block discarded – undo
496 496 
             }
497 497
498 498 
             foreach ($anon['groups'] as $group) {
499 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
499 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
500 500 
             }
501 501
502 502 
             $name = sprintf('old_sound_rabbit_mq.%s_anon', $key);
 
@@ -519,7 +519,7 @@  discard block
 
 block discarded – undo
519 519 
                 $this->injectLoggedChannel($definition, $key, $group['connection']);
520 520 
             }
521 521
522 
-            $definition->addMethodCall('addConsumers', [new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.' . $key)]);
522 
+            $definition->addMethodCall('addConsumers', [new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.'.$key)]);
523 523
524 524 
             if (array_key_exists('qos_options', $group)) {
525 525 
                 $definition->addMethodCall('setQosOptions', array(
Please login to merge, or discard this patch.