eMAGTechLabs / RabbitMqBundle

RPC/RpcClient.php

Spacing +1 added lines, -1 removed lines

@@ -124,7 +124,7 @@
         }
 
         $replices = [];
-        foreach($this->messages as $message) {
+        foreach ($this->messages as $message) {
             /** @var AMQPMessage $message */
             if (!$message->has('correlation_id')) {
                 $this->logger->error('unexpected message. rpc replies have no correlation_id ');

DependencyInjection/OldSoundRabbitMqExtension.php

Spacing +7 added lines, -7 removed lines

@@ -51,7 +51,7 @@ 
     {
         $this->container = $container;
 
-        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__ . '/../Resources/config')));
+        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__.'/../Resources/config')));
         $loader->load('rabbitmq.xml');
 
         $configuration = $this->getConfiguration($configs, $container);
@@ -103,11 +103,11 @@ 
      */
     protected function loadExchanges($exchanges): array
     {
-        return array_map(function ($exchange) {
+        return array_map(function($exchange) {
             $exchangeDeclaration = new Definition(ExchangeDeclaration::class);
             $exchangeDeclaration->setProperties($exchange);
 
-            foreach($this->loadBindings($exchange['bindings'], $exchange['name'], null) as $binding) {
+            foreach ($this->loadBindings($exchange['bindings'], $exchange['name'], null) as $binding) {
                 $this->container->getDefinition('old_sound_rabbit_mq.declaration_registry')->addMethodCall('addBinding', [$binding]);
             }
 
@@ -121,7 +121,7 @@ 
      */
     protected function loadQueues($queues): array
     {
-        return array_map(function ($queue, $key) use ($queues) {
+        return array_map(function($queue, $key) use ($queues) {
             $queue['name'] = $queue['name'] ?? $key;
             $queueDeclaration = new Definition(QueueDeclaration::class);
             $queueDeclaration->setProperties($queue);
@@ -255,7 +255,7 @@ 
     {
         foreach ($this->config['consumers'] as $consumerName => $consumer) {
             $alias = sprintf('old_sound_rabbit_mq.consumer.%s', $consumerName);
-            $serializerAlias = sprintf('old_sound_rabbit_mq.consumer.%s.serializer', $consumerName);// TODO
+            $serializerAlias = sprintf('old_sound_rabbit_mq.consumer.%s.serializer', $consumerName); // TODO
 
             $connectionName = $consumer['connection'] ?? 'default';
 
@@ -266,7 +266,7 @@ 
             $definition->addTag('old_sound_rabbit_mq.consumer', ['consumer' => $consumerName]);
             // TODO $this->container->setAlias($serializerAlias, SerializerInterface::class);
             // $definition->addMethodCall('setSerializer', [new Reference($serializerAlias)]);}
-            foreach($consumer['consumeQueues'] as $index => $consumeQueue) {
+            foreach ($consumer['consumeQueues'] as $index => $consumeQueue) {
                 $queueConsumingDef = new Definition(ConsumeOptions::class);
                 $queueConsumingDef->setProperties([
                     'queueName' => $consumeQueue['queue'],
@@ -432,7 +432,7 @@ 
         $definition->addTag('monolog.logger', [
             'channel' => 'phpamqplib'
         ]);
-        $loggerAlias = $definitionAlias . '.loggeer';
+        $loggerAlias = $definitionAlias.'.loggeer';
         $this->container->setAlias($loggerAlias, 'logger');
         $definition->addMethodCall('setLogger', [new Reference($loggerAlias, ContainerInterface::IGNORE_ON_INVALID_REFERENCE)]);
     }

ReceiverExecutor/ReplyReceiverExecutor.php

Spacing +1 added lines, -1 removed lines

@@ -52,7 +52,7 @@
         $message = new AMQPMessage($body, ['content_type' => 'text/plain'] + $this->options->replayMessageProperties + [
             $this->options->correlationIdProperty => $correlationId,
         ]);
-        $channel->basic_publish($message , '', $replyTo);
+        $channel->basic_publish($message, '', $replyTo);
     }
 
     public function support($receiver): bool

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