eMAGTechLabs / RabbitMqBundle

Command/RpcServerCommand.php

Indentation +2 added lines, -2 removed lines

@@ -42,8 +42,8 @@
         }
 
         $this->getContainer()
-               ->get(sprintf('old_sound_rabbit_mq.%s_server', $input->getArgument('name')))
-               ->start($amount);
+                ->get(sprintf('old_sound_rabbit_mq.%s_server', $input->getArgument('name')))
+                ->start($amount);
 
         return 0;
     }

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;

Command/GroupConsumerCommand.php

Spacing +2 added lines, -2 removed lines

@@ -44,8 +44,8 @@
             ->addOption('connection', 'c', InputOption::VALUE_OPTIONAL, 'Rabbitmq connection name', 'default')
             ->addOption('timeout', 't', InputOption::VALUE_OPTIONAL, 'Timeout', 500)
             ->addOption('qos-prefetch-size', null, InputOption::VALUE_OPTIONAL, 'Qos prefetch size', 0)
-            ->addOption('qos-prefetch-count', null,InputOption::VALUE_OPTIONAL, 'Qos prefetch count', 10)
-            ->addOption('qos-global', null,InputOption::VALUE_OPTIONAL, 'Qos global', true)
+            ->addOption('qos-prefetch-count', null, InputOption::VALUE_OPTIONAL, 'Qos prefetch count', 10)
+            ->addOption('qos-global', null, InputOption::VALUE_OPTIONAL, 'Qos global', true)
             // TODO ?! ->addOption('messages', 'm', InputOption::VALUE_OPTIONAL, 'Messages to consume', 0)
             // ->addOption('memory-limit', 'l', InputOption::VALUE_OPTIONAL, 'Allowed memory for this process (MB)', null)
             // ->addOption('debug', 'd', InputOption::VALUE_NONE, 'Enable Debugging')