@@ -88,8 +88,7 @@ discard block |
||
88 | 88 | |
89 | 89 | $this->tag = |
90 | 90 | !empty($this->tag) ? |
91 | - $this->tag : |
|
92 | - \vsprintf('[host: %s]-[pid: %s]-[queue: %s]', [\gethostname(), \getmypid(), $this->queue->name()]); |
|
91 | + $this->tag : \vsprintf('[host: %s]-[pid: %s]-[queue: %s]', [\gethostname(), \getmypid(), $this->queue->name()]); |
|
93 | 92 | |
94 | 93 | $this->queue->logger($this->logger); |
95 | 94 | } |
@@ -217,7 +216,7 @@ discard block |
||
217 | 216 | */ |
218 | 217 | $subscription->subscribe( |
219 | 218 | $consumer, |
220 | - function ($message, $consumer) use ($context) { |
|
219 | + function($message, $consumer) use ($context) { |
|
221 | 220 | return $this->handle($message, $consumer, $context); |
222 | 221 | } |
223 | 222 | ); |
@@ -89,12 +89,12 @@ |
||
89 | 89 | $properties, |
90 | 90 | \array_filter( |
91 | 91 | $this->config, |
92 | - function ($value) { |
|
92 | + function($value) { |
|
93 | 93 | return $value === true; |
94 | 94 | } |
95 | 95 | ) |
96 | 96 | ), |
97 | - function ($a, $b) { |
|
97 | + function($a, $b) { |
|
98 | 98 | return ($a | $b); |
99 | 99 | }, |
100 | 100 | (AmqpQueue::FLAG_NOPARAM) |
@@ -97,12 +97,12 @@ |
||
97 | 97 | $properties, |
98 | 98 | \array_filter( |
99 | 99 | $this->config, |
100 | - function ($value) { |
|
100 | + function($value) { |
|
101 | 101 | return $value === true; |
102 | 102 | } |
103 | 103 | ) |
104 | 104 | ), |
105 | - function ($a, $b) { |
|
105 | + function($a, $b) { |
|
106 | 106 | return ($a | $b); |
107 | 107 | }, |
108 | 108 | (AmqpTopic::FLAG_NOPARAM) |
@@ -140,7 +140,7 @@ |
||
140 | 140 | // Remove the attributes with null value. |
141 | 141 | $config = \array_filter( |
142 | 142 | $config, |
143 | - function ($value) { |
|
143 | + function($value) { |
|
144 | 144 | return null !== $value; |
145 | 145 | } |
146 | 146 | ); |
@@ -292,7 +292,7 @@ |
||
292 | 292 | |
293 | 293 | if (empty($processor)) { |
294 | 294 | $processor = new CallbackProcessor( |
295 | - function () { |
|
295 | + function() { |
|
296 | 296 | return false; |
297 | 297 | } |
298 | 298 | ); |