eMAGTechLabs / RabbitMqBundle

Command/ConsumerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -113,7 +113,7 @@
             new ConsoleLogger($output)
         );
         $declarationRegistry = $this->container->get('old_sound_rabbit_mq.declaration_registry');
-        foreach($consumer->getConsumings() as $queueConsuming) {
+        foreach ($consumer->getConsumings() as $queueConsuming) {
             $declarator->declareForQueueDeclaration($queueConsuming->queue, $declarationRegistry);
         }
     }

RabbitMq/Consumer.php

Spacing +4 added lines, -4 removed lines

@@ -75,7 +75,7 @@ 
 
     protected function setup(): Consumer
     {
-        foreach($this->consumings as $index => $consuming) {
+        foreach ($this->consumings as $index => $consuming) {
             $this->channel->basic_qos($consuming->options->qosPrefetchSize, $consuming->options->qosPrefetchCount, false);
 
             $options = $consuming->options;
@@ -87,7 +87,7 @@ 
                 $options->noAck,
                 $options->exclusive,
                 false,
-                function (AMQPMessage $message) use ($consuming) {
+                function(AMQPMessage $message) use ($consuming) {
                     $flags = $consuming->executeReceiverStrategy->onConsumeCallback($message);
                     if ($flags) {
                         $this->handleProcessMessages($flags, $consuming);
@@ -200,7 +200,7 @@ 
                     break;
                 }
             } catch (AMQPTimeoutException $e) {
-                foreach($this->executeReceiverStrategies as $executeReceiverStrategy) {
+                foreach ($this->executeReceiverStrategies as $executeReceiverStrategy) {
                     $executeReceiverStrategy->onCatchTimeout($e);
                 }
                 $now = new \DateTime();
@@ -228,7 +228,7 @@ 
 
     private function handleProcessMessages(array $flags, Consuming $consuming)
     {
-        $ack = !array_search(fn ($reply) => $reply !== ReceiverInterface::MSG_ACK, $flags, true);
+        $ack = !array_search(fn($reply) => $reply !== ReceiverInterface::MSG_ACK, $flags, true);
         if ($this->multiAck && count($flags) > 1 && $ack) {
             $lastDeliveryTag = array_key_last($flags);