eMAGTechLabs / RabbitMqBundle

RabbitMq/Consumer.php

Spacing +1 added lines, -1 removed lines

@@ -268,7 +268,7 @@
     {
         if ($this->gracefulMaxExecutionDateTime) {
             $allowedExecutionDateInterval = $this->gracefulMaxExecutionDateTime->diff(new \DateTime());
-            $allowedExecutionSeconds =  $allowedExecutionDateInterval->days * 86400
+            $allowedExecutionSeconds = $allowedExecutionDateInterval->days * 86400
                 + $allowedExecutionDateInterval->h * 3600
                 + $allowedExecutionDateInterval->i * 60
                 + $allowedExecutionDateInterval->s;

RabbitMq/RpcClient.php

Indentation +4 added lines, -4 removed lines

@@ -39,12 +39,12 @@
         }
 
         $msg = new AMQPMessage($msgBody, array('content_type' => 'text/plain',
-                                               'reply_to' => $this->directReplyTo
+                                                'reply_to' => $this->directReplyTo
                                                    ? 'amq.rabbitmq.reply-to' // On direct reply-to mode, use predefined queue name
                                                    : $this->getQueueName(),
-                                               'delivery_mode' => 1, // non durable
-                                               'expiration' => $expiration*1000,
-                                               'correlation_id' => $requestId));
+                                                'delivery_mode' => 1, // non durable
+                                                'expiration' => $expiration*1000,
+                                                'correlation_id' => $requestId));
 
         $this->getChannel()->basic_publish($msg, $server, $routingKey);
 

Spacing +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
                                                    ? 'amq.rabbitmq.reply-to' // On direct reply-to mode, use predefined queue name
                                                    : $this->getQueueName(),
                                                'delivery_mode' => 1, // non durable
-                                               'expiration' => $expiration*1000,
+                                               'expiration' => $expiration * 1000,
                                                'correlation_id' => $requestId));
 
         $this->getChannel()->basic_publish($msg, $server, $routingKey);
@@ -102,7 +102,7 @@ 
     protected function getQueueName(): ?string
     {
         if (null === $this->queueName) {
-            list($this->queueName, ,) = $this->getChannel()->queue_declare("", false, false, true, false);
+            list($this->queueName,,) = $this->getChannel()->queue_declare("", false, false, true, false);
         }
 
         return $this->queueName;

RabbitMq/Producer.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
             $msg->set('application_headers', $headersTable);
         }
 
-        $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string)$routingKey);
+        $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string) $routingKey);
         $this->logger->debug('AMQP message published', array(
             'amqp' => array(
                 'body' => $msgBody,

RabbitMq/DynamicConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -4,7 +4,7 @@
 
 use OldSound\RabbitMqBundle\Provider\QueueOptionsProviderInterface;
 
-class DynamicConsumer extends Consumer{
+class DynamicConsumer extends Consumer {
 
     /**
      * Queue provider

Command/DeleteCommand.php

Indentation +2 added lines, -2 removed lines

@@ -16,8 +16,8 @@
     protected function configure()
     {
         $this->addArgument('name', InputArgument::REQUIRED, 'Consumer Name')
-             ->setDescription('Delete a consumer\'s queue')
-             ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before deleting');
+                ->setDescription('Delete a consumer\'s queue')
+                ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before deleting');
 
         $this->setName('rabbitmq:delete');
     }

Command/PurgeConsumerCommand.php

Indentation +2 added lines, -2 removed lines

@@ -16,8 +16,8 @@
     protected function configure()
     {
         $this->addArgument('name', InputArgument::REQUIRED, 'Consumer Name')
-             ->setDescription('Purge a consumer\'s queue')
-             ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before purging');
+                ->setDescription('Purge a consumer\'s queue')
+                ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before purging');
 
         $this->setName('rabbitmq:purge');
     }

Command/SetupFabricCommand.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
         $partsHolder = $this->getContainer()->get('old_sound_rabbit_mq.parts_holder');
 
         foreach (array('base_amqp', 'binding') as $key) {
-            foreach ($partsHolder->getParts('old_sound_rabbit_mq.' . $key) as $baseAmqp) {
+            foreach ($partsHolder->getParts('old_sound_rabbit_mq.'.$key) as $baseAmqp) {
                 if ($baseAmqp instanceof DynamicConsumer) {
                     continue;
                 }

MemoryChecker/MemoryConsumptionChecker.php

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
             }
         }
 
-        return (int)$numerical;
+        return (int) $numerical;
     }
 
 }

Tests/RabbitMq/RpcClientTest.php

Spacing +2 added lines, -2 removed lines

@@ -26,7 +26,7 @@ 
         $serializer->expects($this->once())->method('deserialize')->with('message', 'json', null);
         $client->initClient(true);
         $client->setUnserializer(function($data) use ($serializer) {
-            $serializer->deserialize($data, 'json','');
+            $serializer->deserialize($data, 'json', '');
         });
         $client->processMessage($message);
     }
@@ -45,7 +45,7 @@ 
             ->setConstructorArgs(array($expectedNotify))
             ->getMock();
         $notified = false;
-        $client->notify(function ($message) use (&$notified) {
+        $client->notify(function($message) use (&$notified) {
             $notified = $message;
         });