View GitHub Repository RabbitMqBundle

Schedule Inspection
Subscribe
Test Failed
Pull Request — master (#38)
by Aleksandr
08:24
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'])) {
 
@@ -255,7 +255,7 @@  discard block
 
 block discarded – undo
255 255
256 256 
             if (empty($consumer['queues']) && empty($consumer['queues_provider'])) {
257 257 
                 throw new InvalidConfigurationException(
258 
-                    "Error on loading $key multiple consumer. " .
258 
+                    "Error on loading $key multiple consumer. ".
259 259 
                     "Either 'queues' or 'queues_provider' parameters should be defined."
260 260 
                 );
261 261 
             }
 
@@ -275,7 +275,7 @@  discard block
 
 block discarded – undo
275 275 
                 ->addMethodCall('setQueues', array($this->normalizeArgumentKeys($queues)));
276 276
277 277 
             foreach ($consumer['groups'] as $group) {
278 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
278 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
279 279 
             }
280 280
281 281 
             if ($consumer['queues_provider']) {
 
@@ -339,7 +339,7 @@  discard block
 
 block discarded – undo
339 339
340 340 
             if (empty($consumer['queue_options_provider'])) {
341 341 
                 throw new InvalidConfigurationException(
342 
-                    "Error on loading $key dynamic consumer. " .
342 
+                    "Error on loading $key dynamic consumer. ".
343 343 
                     "'queue_provider' parameter should be defined."
344 344 
                 );
345 345 
             }
 
@@ -354,7 +354,7 @@  discard block
 
 block discarded – undo
354 354 
                 ->addMethodCall('setCallback', array(array(new Reference($consumer['callback']), 'execute')));
355 355
356 356 
             foreach ($consumer['groups'] as $group) {
357 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
357 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
358 358 
             }
359 359
360 360 
             if (array_key_exists('qos_options', $consumer)) {
 
@@ -432,7 +432,7 @@  discard block
 
 block discarded – undo
432 432 
             ;
433 433
434 434 
             foreach ($consumer['groups'] as $group) {
435 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
435 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
436 436 
             }
437 437
438 438 
             if (isset($consumer['idle_timeout_exit_code'])) {
 
@@ -487,7 +487,7 @@  discard block
 
 block discarded – undo
487 487 
             }
488 488
489 489 
             foreach ($consumer['groups'] as $group) {
490 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
490 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
491 491 
             }
492 492
493 493 
             $name = sprintf('old_sound_rabbit_mq.%s_anon', $key);
 
@@ -510,7 +510,7 @@  discard block
 
 block discarded – undo
510 510 
                 $this->injectLoggedChannel($definition, $key, $group['connection']);
511 511 
             }
512 512
513 
-            $definition->addMethodCall('addConsumers', [new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.' . $key)]);
513 
+            $definition->addMethodCall('addConsumers', [new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.'.$key)]);
514 514
515 515 
             if (array_key_exists('qos_options', $group)) {
516 516 
                 $definition->addMethodCall('setQosOptions', array(
Please login to merge, or discard this patch.