eMAGTechLabs / RabbitMqBundle

RabbitMq/Consumer.php

Spacing +6 added lines, -6 removed lines

@@ -89,7 +89,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;
@@ -101,7 +101,7 @@ 
                 $options->noAck,
                 $options->exclusive,
                 false,
-                function (AMQPMessage $message) use ($consuming) {
+                function(AMQPMessage $message) use ($consuming) {
                     $consuming->executeReceiverStrategy->onConsumeCallback($message);
                     $this->maybeStopConsumer();
                 });
@@ -207,7 +207,7 @@ 
                     break;
                 }
             } catch (AMQPTimeoutException $e) {
-                foreach($this->executeReceiverStrategies as $executeReceiverStrategy) {
+                foreach ($this->executeReceiverStrategies as $executeReceiverStrategy) {
                     $executeReceiverStrategy->onCatchTimeout($e);
                 }
                 $now = new \DateTime();
@@ -290,7 +290,7 @@ 
 
         if (!$queueConsuming->noAck) {
             $messages = array_combine(
-                array_map(fn ($message) => $message->getDeliveryTag(), $messages),
+                array_map(fn($message) => $message->getDeliveryTag(), $messages),
                 $messages
             );
 
@@ -306,9 +306,9 @@ 
     {
         $executeReceiverStrategy = $this->getExecuteReceiverStrategy($queueConsuming);
 
-        $ack = !array_search(fn ($reply) => $reply !== ReceiverInterface::MSG_ACK, $replies, true);
+        $ack = !array_search(fn($reply) => $reply !== ReceiverInterface::MSG_ACK, $replies, true);
         if ($this->multiAck && count($messages) > 1 && $ack) {
-            $channels = array_map(fn ($message) => $message->getChannel(), $messages);
+            $channels = array_map(fn($message) => $message->getChannel(), $messages);
             if (count($channels) !== array_unique($channels)) { // all messages have same channel
                 throw new InvalidArgumentException('Messages can not be processed as multi ack with different channels');
             }

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