eMAGTechLabs / RabbitMqBundle

RabbitMq/Binding.php

Indentation +2 added lines, -2 removed lines

@@ -34,12 +34,12 @@
      */
     protected $arguments;
 
-     public function getExchange(): string
+        public function getExchange(): string
     {
         return $this->exchange;
     }
 
-     public function setExchange(string $exchange): void
+        public function setExchange(string $exchange): void
     {
         $this->exchange = $exchange;
     }

RabbitMq/RpcServer.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
     public function initServer(string $name): void
     {
         $this->setExchangeOptions(array('name' => $name, 'type' => 'direct'));
-        $this->setQueueOptions(array('name' => $name . '-queue'));
+        $this->setQueueOptions(array('name' => $name.'-queue'));
     }
 
     public function processMessage(AMQPMessage $msg): void
@@ -25,7 +25,7 @@ 
             $this->consumed++;
             $this->maybeStopConsumer();
         } catch (\Exception $e) {
-            $this->sendReply('error: ' . $e->getMessage(), $msg->get('reply_to'), $msg->get('correlation_id'));
+            $this->sendReply('error: '.$e->getMessage(), $msg->get('reply_to'), $msg->get('correlation_id'));
         }
     }
 

RabbitMq/BaseConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
     /**
      * @throws \ErrorException
      */
-    public function start (int $msgAmount = 0): void
+    public function start(int $msgAmount = 0): void
     {
         $this->target = $msgAmount;
 

RabbitMq/BaseAmqp.php

Spacing +1 added lines, -1 removed lines

@@ -207,7 +207,7 @@
     protected function queueDeclare(): void
     {
         if ($this->queueOptions['declare']) {
-            list($queueName, ,) = $this->getChannel()->queue_declare($this->queueOptions['name'], $this->queueOptions['passive'],
+            list($queueName,,) = $this->getChannel()->queue_declare($this->queueOptions['name'], $this->queueOptions['passive'],
                 $this->queueOptions['durable'], $this->queueOptions['exclusive'],
                 $this->queueOptions['auto_delete'], $this->queueOptions['nowait'],
                 $this->queueOptions['arguments'], $this->queueOptions['ticket']);

Command/BaseConsumerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -109,7 +109,7 @@
         $this->consumer = $this->getContainer()
                 ->get(sprintf($this->getConsumerService(), $input->getArgument('name')));
 
-        if (!is_null($input->getOption('memory-limit')) && ctype_digit((string) $input->getOption('memory-limit')) && (int)$input->getOption('memory-limit') > 0) {
+        if (!is_null($input->getOption('memory-limit')) && ctype_digit((string) $input->getOption('memory-limit')) && (int) $input->getOption('memory-limit') > 0) {
             $this->consumer->setMemoryLimit($input->getOption('memory-limit'));
         }
         $this->consumer->setRoutingKey($input->getOption('route'));