eMAGTechLabs / RabbitMqBundle

Tests/RabbitMq/ConsumerTest.php

Spacing +13 added lines, -13 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);
                     })
@@ -220,7 +220,7 @@ 
         $amqpChannel->expects($this->exactly(1))
             ->method('wait')
             ->with(null, false, $consumer->getIdleTimeout())
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the last activity date time
                 $consumer->setLastActivityDateTime(new \DateTime("-$waitTimeout seconds"));
                 throw new AMQPTimeoutException();
@@ -255,7 +255,7 @@ 
         $amqpChannel->expects($this->exactly(2))
             ->method('wait')
             ->with(null, false, $consumer->getIdleTimeout())
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the last activity date time
                 $consumer->setLastActivityDateTime(new \DateTime("-$waitTimeout seconds"));
                 throw new AMQPTimeoutException();
@@ -268,7 +268,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;
@@ -277,7 +277,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;
@@ -316,7 +316,7 @@ 
 
         $amqpChannel->expects($this->exactly(1))
             ->method('wait')
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the max execution date time
                 $consumer->setGracefulMaxExecutionDateTimeFromSecondsInTheFuture($waitTimeout * -1);
                 throw new AMQPTimeoutException();
@@ -383,8 +383,8 @@ 
 
         $amqpChannel->expects($this->exactly(2))
             ->method('wait')
-            ->with(null, false, $this->LessThanOrEqual($consumer->getTimeoutWait()) )
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->with(null, false, $this->LessThanOrEqual($consumer->getTimeoutWait()))
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // ensure max execution date time "counts down"
                 $consumer->setGracefulMaxExecutionDateTime(
                     $consumer->getGracefulMaxExecutionDateTime()->modify("-$waitTimeout seconds")
@@ -425,7 +425,7 @@ 
         $amqpChannel->expects($this->once())
             ->method('wait')
             ->with(null, false, $consumer->getGracefulMaxExecutionDateTime()->diff(new \DateTime())->s)
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the max execution date time
                 $consumer->setGracefulMaxExecutionDateTimeFromSecondsInTheFuture($waitTimeout * -1);
                 throw new AMQPTimeoutException();
@@ -463,7 +463,7 @@ 
         $amqpChannel->expects($this->once())
             ->method('wait')
             ->with(null, false, 10)
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the last activity date time
                 $consumer->setLastActivityDateTime(new \DateTime("-$waitTimeout seconds"));
                 throw new AMQPTimeoutException();

Command/BatchConsumerCommand.php

Spacing +2 added lines, -2 removed lines

@@ -78,7 +78,7 @@ 
             define('AMQP_DEBUG', (bool) $input->getOption('debug'));
         }
 
-        $this->amount = (int)$input->getOption('messages');
+        $this->amount = (int) $input->getOption('messages');
 
         if (0 > (int) $this->amount) {
             throw new \InvalidArgumentException("The -m option should be null or greater than 0");
@@ -86,7 +86,7 @@ 
 
         $this->initConsumer($input);
 
-        return $this->consumer->consume((int)$this->amount);
+        return $this->consumer->consume((int) $this->amount);
     }
 
     /**