eMAGTechLabs / RabbitMqBundle

Command/DeclareCommand.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
 
         $connection = $input->getArgument('connection');
         $channelAlias = sprintf('old_sound_rabbit_mq.channel.%s', $connection);
-        if(!$this->container->has($channelAlias)) {
+        if (!$this->container->has($channelAlias)) {
             throw new InvalidOptionException('Connection is not exist');
         };
 

Declarations/DeclarationsRegistry.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
      */
     public function getBindingsByExchange(ExchangeDeclaration $exchange): array
     {
-        return array_filter($this->bindings, function ($binding) use ($exchange) {
+        return array_filter($this->bindings, function($binding) use ($exchange) {
             return $binding->exchange === $exchange->name || ($binding->destinationIsExchange && $binding->destination === $exchange->name);
         });
     }

Declarations/QueueDeclaration.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
      */
     public function declure() {
         foreach ($this->queues as $name => $options) {
-            list($queueName, ,) = $this->getChannel()->queue_declare($name, $options['passive'],
+            list($queueName,,) = $this->getChannel()->queue_declare($name, $options['passive'],
                 $options['durable'], $options['exclusive'],
                 $options['auto_delete'], $options['nowait'],
                 $options['arguments'], $options['ticket']);

Declarations/ConsumerFactory.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
         $consumer = new Consumer($consumerDef->name);
         $consumer->setChannel($connection->channel());
 
-        foreach([] as $d) {
+        foreach ([] as $d) {
             $consumer->consumeQueue();
         }
 

Declarations/Declarator.php

Spacing +5 added lines, -5 removed lines

@@ -106,7 +106,7 @@ 
     public function declareForExchange(ExchangeDeclaration $exchange, DeclarationsRegistry $declarationsRegistry) 
     {
         $bindings = $declarationsRegistry->getBindingsByExchange($exchange);
-        $queues = array_filter($bindings, function ($binding) use($exchange) {
+        $queues = array_filter($bindings, function($binding) use($exchange) {
             false === $binding->destinationIsExchange && $binding->destination == $exchange->name;
         });
 
@@ -117,7 +117,7 @@ 
 
     public function declareForQueueDeclaration(string $queueName, DeclarationsRegistry $declarationsRegistry)
     {
-        $consumerQueues = array_filter($declarationsRegistry->queues, function ($queue) use ($queueName) {
+        $consumerQueues = array_filter($declarationsRegistry->queues, function($queue) use ($queueName) {
             return $queue->name === $queueName;
             // TODO not found! exception?
         });
@@ -126,7 +126,7 @@ 
         $bindings = [];
         $exchanges = [];
         foreach ($consumerQueues as $queue) {
-            $b = array_filter($declarationsRegistry->bindings, function ($binding) use ($queue) {
+            $b = array_filter($declarationsRegistry->bindings, function($binding) use ($queue) {
                 return !$binding->destinationIsExchange && $binding->destination === $queue->name;
             });
             $bindings = array_merge($bindings, $b);
@@ -138,7 +138,7 @@ 
             }
         }
 
-        $exchanges = array_map(fn ($exchange) => $declarationsRegistry->exchanges[$exchange], array_unique($exchanges));
+        $exchanges = array_map(fn($exchange) => $declarationsRegistry->exchanges[$exchange], array_unique($exchanges));
         $this->declareExchanges($exchanges);
         $this->declareQueues($consumerQueues);
         $this->declareBindings($bindings);
@@ -146,7 +146,7 @@ 
     
     public function declareForQueue(QueueDeclaration $queue)
     {
-        $exchanges = array_map(function ($binding) {
+        $exchanges = array_map(function($binding) {
             return $binding->exchange;
         }, $queue->bindings);
 

DependencyInjection/Compiler/ConsumersListCompilerPass.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
     public function process(ContainerBuilder $container)
     {
         $taggedConsumers = $container->findTaggedServiceIds('old_sound_rabbit_mq.consumer');
-        $consumerNames = array_map(fn ($tags) => $tags[0]['consumer'], $taggedConsumers);
+        $consumerNames = array_map(fn($tags) => $tags[0]['consumer'], $taggedConsumers);
         $container->setParameter('old_sound_rabbit_mq.allowed_consumer_names', $consumerNames);
     }
 }
\ No newline at end of file

DependencyInjection/Compiler/ExtraContextLoggerCompilerPass.php

Spacing +2 added lines, -2 removed lines

@@ -22,7 +22,7 @@ 
 
         foreach ($taggedProducers as $id => $tags) {
             $producerName = $tags[0]['producer'];
-            $originLogger = $id . '.logger';
+            $originLogger = $id.'.logger';
 
             if ($container->hasDefinition($originLogger)) {
                 $consumerDef = $container->getDefinition($id);
@@ -34,7 +34,7 @@ 
 
         foreach ($taggedConsumers as $id => $tags) {
             $consumerName = $tags[0]['consumer'];
-            $originLogger = $id . '.logger';
+            $originLogger = $id.'.logger';
 
             if ($container->hasDefinition($originLogger)) {
                 $consumerDef = $container->getDefinition($id);

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