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