eMAGTechLabs / RabbitMqBundle

Tests/RabbitMq/MultipleConsumerTest.php

Spacing +3 added lines, -3 removed lines

@@ -246,14 +246,14 @@ 
     {
         $this->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.
             }));
 
         $this->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.
             }));
     }
@@ -266,7 +266,7 @@ 
      */
     private function prepareCallback($processFlag)
     {
-        return function ($msg) use ($processFlag) {
+        return function($msg) use ($processFlag) {
             return $processFlag;
         };
     }

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;
     }