eMAGTechLabs / RabbitMqBundle

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