eMAGTechLabs / RabbitMqBundle

EventListener/PcntlSignalDispatchSubscriber.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 
     public function __construct(Consumer $consumer)
     {
-        $stopConsumer = function () use ($consumer) {
+        $stopConsumer = function() use ($consumer) {
             // Process current message, then halt consumer
             $consumer->forceStopConsumer();
             // Halt consumer if waiting for a new message from the queue

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