View GitHub Repository RabbitMqBundle

Schedule Inspection
Subscribe
Completed
Pull Request — master (#38)
by Aleksandr
06:01
created
Status
Category
Toggle Patches
DependencyInjection/OldSoundRabbitMqExtension.php 1 patch
Spacing   +10 added lines, -10 removed lines patch added patch discarded remove patch 
@@ -39,7 +39,7 @@  discard block
 
 block discarded – undo
39 39 
     {
40 40 
         $this->container = $container;
41 41
42 
-        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__ . '/../Resources/config')));
42 
+        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__.'/../Resources/config')));
43 43 
         $loader->load('rabbitmq.xml');
44 44
45 45 
         $configuration = $this->getConfiguration($configs, $container);
 
@@ -192,7 +192,7 @@  discard block
 
 block discarded – undo
192 192 
             $definition->addTag('old_sound_rabbit_mq.consumer');
193 193 
             foreach ($consumer['groups'] as $group) {
194 194 
                 $this->groups[] = $group;
195 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
195 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
196 196 
             }
197 197 
             //this consumer doesn't define an exchange -> using AMQP Default
198 198 
             if (!isset($consumer['exchange_options'])) {
 
@@ -260,7 +260,7 @@  discard block
 
 block discarded – undo
260 260
261 261 
             if (empty($consumer['queues']) && empty($consumer['queues_provider'])) {
262 262 
                 throw new InvalidConfigurationException(
263 
-                    "Error on loading $key multiple consumer. " .
263 
+                    "Error on loading $key multiple consumer. ".
264 264 
                     "Either 'queues' or 'queues_provider' parameters should be defined."
265 265 
                 );
266 266 
             }
 
@@ -281,7 +281,7 @@  discard block
 
 block discarded – undo
281 281
282 282 
             foreach ($consumer['groups'] as $group) {
283 283 
                 $this->groups[] = $group;
284 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
284 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
285 285 
             }
286 286
287 287 
             if ($consumer['queues_provider']) {
 
@@ -348,7 +348,7 @@  discard block
 
 block discarded – undo
348 348
349 349 
             if (empty($consumer['queue_options_provider'])) {
350 350 
                 throw new InvalidConfigurationException(
351 
-                    "Error on loading $key dynamic consumer. " .
351 
+                    "Error on loading $key dynamic consumer. ".
352 352 
                     "'queue_provider' parameter should be defined."
353 353 
                 );
354 354 
             }
 
@@ -364,7 +364,7 @@  discard block
 
 block discarded – undo
364 364
365 365 
             foreach ($consumer['groups'] as $group) {
366 366 
                 $this->groups[] = $group;
367 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
367 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
368 368 
             }
369 369
370 370 
             if (array_key_exists('qos_options', $consumer)) {
 
@@ -446,7 +446,7 @@  discard block
 
 block discarded – undo
446 446
447 447 
             foreach ($consumer['groups'] as $group) {
448 448 
                 $this->groups[] = $group;
449 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
449 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
450 450 
             }
451 451
452 452 
             if (isset($consumer['idle_timeout_exit_code'])) {
 
@@ -502,7 +502,7 @@  discard block
 
 block discarded – undo
502 502
503 503 
             foreach ($anon['groups'] as $group) {
504 504 
                 $this->groups[] = $group;
505 
-                $definition->addTag('old_sound_rabbit_mq.consumer.group.' . $group);
505 
+                $definition->addTag('old_sound_rabbit_mq.consumer.group.'.$group);
506 506 
             }
507 507
508 508 
             $name = sprintf('old_sound_rabbit_mq.%s_anon', $key);
 
@@ -528,7 +528,7 @@  discard block
 
 block discarded – undo
528 528 
             $connection = isset($group['connection']) ? $group['connection'] : 'default';
529 529 
             $this->injectConnection($definition, $connection);
530 530 
             if ($this->collectorEnabled) {
531 
-                $this->injectLoggedChannel($definition, $key . '_group_consumer', $connection);
531 
+                $this->injectLoggedChannel($definition, $key.'_group_consumer', $connection);
532 532 
             }
533 533
534 534 
             if ($group['enable_logger']) {
 
@@ -536,7 +536,7 @@  discard block
 
 block discarded – undo
536 536 
             }
537 537
538 538 
             $definition->addMethodCall('addConsumers', array(
539 
-                new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.' . $key))
539 
+                new TaggedIteratorArgument('old_sound_rabbit_mq.consumer.group.'.$key))
540 540 
             );
541 541
542 542 
             if (isset($group['timeout_wait'])) {
Please login to merge, or discard this patch.