View GitHub Repository RabbitMqBundle

Schedule Inspection
Subscribe
Completed
Pull Request — master (#39)
by Aleksandr
06:46
created
Status
Category
Toggle Patches
Declarations/Declarator.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch 
@@ -106,7 +106,7 @@  discard block
 
 block discarded – undo
106 106 
     public function declareForExchange(ExchangeDeclaration $exchange, DeclarationsRegistry $declarationsRegistry)
107 107 
     {
108 108 
         $bindings = $declarationsRegistry->getBindingsByExchange($exchange);
109 
-        $queues = array_filter($bindings, function ($binding) use($exchange) {
109 
+        $queues = array_filter($bindings, function($binding) use($exchange) {
110 110 
             false === $binding->destinationIsExchange && $binding->destination == $exchange->name;
111 111 
         });
112 112 
 
@@ -117,7 +117,7 @@  discard block
 
 block discarded – undo
117 117
118 118 
     public function declareForQueueDeclaration(string $queueName, DeclarationsRegistry $declarationsRegistry)
119 119 
     {
120 
-        $consumerQueues = array_filter($declarationsRegistry->queues, function ($queue) use ($queueName) {
120 
+        $consumerQueues = array_filter($declarationsRegistry->queues, function($queue) use ($queueName) {
121 121 
             return $queue->name === $queueName;
122 122 
             // TODO not found! exception?
123 123 
         });
 
@@ -126,7 +126,7 @@  discard block
 
 block discarded – undo
126 126 
         $bindings = [];
127 127 
         $exchanges = [];
128 128 
         foreach ($consumerQueues as $queue) {
129 
-            $b = array_filter($declarationsRegistry->bindings, function ($binding) use ($queue) {
129 
+            $b = array_filter($declarationsRegistry->bindings, function($binding) use ($queue) {
130 130 
                 return !$binding->destinationIsExchange && $binding->destination === $queue->name;
131 131 
             });
132 132 
             $bindings = array_merge($bindings, $b);
 
@@ -138,7 +138,7 @@  discard block
 
 block discarded – undo
138 138 
             }
139 139 
         }
140 140
141 
-        $exchanges = array_map(fn ($exchange) => $declarationsRegistry->exchanges[$exchange], array_unique($exchanges));
141 
+        $exchanges = array_map(fn($exchange) => $declarationsRegistry->exchanges[$exchange], array_unique($exchanges));
142 142 
         $this->declareExchanges($exchanges);
143 143 
         $this->declareQueues($consumerQueues);
144 144 
         $this->declareBindings($bindings);
 
@@ -146,7 +146,7 @@  discard block
 
 block discarded – undo
146 146
147 147 
     public function declareForQueue(QueueDeclaration $queue)
148 148 
     {
149 
-        $exchanges = array_map(function ($binding) {
149 
+        $exchanges = array_map(function($binding) {
150 150 
             return $binding->exchange;
151 151 
         }, $queue->bindings);
152 152
Please login to merge, or discard this patch.