eMAGTechLabs / RabbitMqBundle

Tests/RabbitMq/ConsumerTest.php

Spacing +6 added lines, -6 removed lines

@@ -49,7 +49,7 @@ 
         $amqpChannel = $this->prepareAMQPChannel();
         $consumer = $this->getConsumer($amqpConnection, $amqpChannel);
 
-        $callbackFunction = function () use ($processFlag) {
+        $callbackFunction = function() use ($processFlag) {
             return $processFlag;
         }; // Create a callback function with a return value set by the data provider.
         $consumer->setCallback($callbackFunction);
@@ -62,14 +62,14 @@ 
         if ($expectedMethod) {
             $amqpChannel->expects($this->any())
                 ->method('basic_reject')
-                ->will($this->returnCallback(function ($delivery_tag, $requeue) use ($expectedMethod, $expectedRequeue) {
+                ->will($this->returnCallback(function($delivery_tag, $requeue) use ($expectedMethod, $expectedRequeue) {
                     Assert::assertSame($expectedMethod, 'basic_reject'); // Check if this function should be called.
                     Assert::assertSame($requeue, $expectedRequeue); // Check if the message should be requeued.
                 }));
 
             $amqpChannel->expects($this->any())
                 ->method('basic_ack')
-                ->will($this->returnCallback(function ($delivery_tag) use ($expectedMethod) {
+                ->will($this->returnCallback(function($delivery_tag) use ($expectedMethod) {
                     Assert::assertSame($expectedMethod, 'basic_ack'); // Check if this function should be called.
                 }));
         } else {
@@ -174,7 +174,7 @@ 
             ->with(null, false, $consumer->getIdleTimeout())
             ->will(
                 $this->returnCallback(
-                    function () use ($amqpChannel) {
+                    function() use ($amqpChannel) {
                         /** remove an element on each loop like ... simulate an ACK */
                         array_splice($amqpChannel->callbacks, 0, 1);
                     })
@@ -259,7 +259,7 @@ 
         $eventDispatcher->expects($this->at(1))
             ->method('dispatch')
             ->with($this->isInstanceOf(OnIdleEvent::class), OnIdleEvent::NAME)
-            ->willReturnCallback(function (OnIdleEvent $event, $eventName) {
+            ->willReturnCallback(function(OnIdleEvent $event, $eventName) {
                 $event->setForceStop(false);
 
                 return $event;
@@ -268,7 +268,7 @@ 
         $eventDispatcher->expects($this->at(3))
             ->method('dispatch')
             ->with($this->isInstanceOf(OnIdleEvent::class), OnIdleEvent::NAME)
-            ->willReturnCallback(function (OnIdleEvent $event, $eventName) {
+            ->willReturnCallback(function(OnIdleEvent $event, $eventName) {
                 $event->setForceStop(true);
 
                 return $event;

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(