eMAGTechLabs / RabbitMqBundle

RabbitMq/AMQPConnectionFactory.php

Spacing +5 added lines, -5 removed lines

@@ -31,7 +31,7 @@ 
     {
         $parameters = $this->parseUrl(array_merge($this->defaultParameters, $parameters));
         if (is_array($parameters['ssl_context'])) {
-            $parameters['ssl_context'] = ! empty($parameters['ssl_context'])
+            $parameters['ssl_context'] = !empty($parameters['ssl_context'])
                 ? stream_context_create(array('ssl' => $parameters['ssl_context']))
                 : null;
         }
@@ -46,10 +46,10 @@ 
             $parameters['user'],
             $parameters['password'],
             $parameters['vhost'],
-            false,      // insist
+            false, // insist
             'AMQPLAIN', // login_method
-            null,       // login_response
-            'en_US',    // locale
+            null, // login_response
+            'en_US', // locale
         ];
 
         $isSocketConnection = $class == \PhpAmqpLib\Connection\AMQPSocketConnection::class || is_subclass_of($class, \PhpAmqpLib\Connection\AMQPSocketConnection::class);
@@ -93,7 +93,7 @@ 
             $parameters['host'] = urldecode($url['host']);
         }
         if (isset($url['port'])) {
-            $parameters['port'] = (int)$url['port'];
+            $parameters['port'] = (int) $url['port'];
         }
         if (isset($url['user'])) {
             $parameters['user'] = urldecode($url['user']);

RabbitMq/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 ');

Serializer/JsonMessageBodySerializer.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
                 'message' => $body->getMessage(),
             ]);
         }
-        return json_encode($body);// $this->serializer->serialize($body, 'json');
+        return json_encode($body); // $this->serializer->serialize($body, 'json');
     }
 
     public function deserialize(string $body)

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->getQueueConsumings() as $queueConsuming) {
+        foreach ($consumer->getQueueConsumings() as $queueConsuming) {
             $declarator->declareForQueueDeclaration($queueConsuming->queueName, $declarationRegistry);
         }
     }

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