@@ -33,7 +33,7 @@ |
||
| 33 | 33 | $total += count($this->jobs[$jobWorkerName]); |
| 34 | 34 | } |
| 35 | 35 | |
| 36 | - return array_sum(array_map(function ($jobs) { return count($jobs); }, $this->jobs)); |
|
| 36 | + return array_sum(array_map(function($jobs) { return count($jobs); }, $this->jobs)); |
|
| 37 | 37 | } |
| 38 | 38 | |
| 39 | 39 | public function getStatus() |
@@ -98,7 +98,7 @@ |
||
| 98 | 98 | $this->eventDispatcher->dispatch(Event::PRE_JOB, $event); |
| 99 | 99 | |
| 100 | 100 | $start = microtime(true); |
| 101 | - $handleException = function (\Exception $exception) use ($job) { |
|
| 101 | + $handleException = function(\Exception $exception) use ($job) { |
|
| 102 | 102 | /** @var \Exception $exception */ |
| 103 | 103 | $exceptionMessage = get_class($exception)."\n".$exception->getCode().' - '.$exception->getMessage()."\n".$exception->getTraceAsString(); |
| 104 | 104 | $this->log('debug', "Failed: {$job->getClassName()}->{$job->getMethod()}"); |
@@ -89,7 +89,7 @@ discard block |
||
| 89 | 89 | $rootNode |
| 90 | 90 | ->prototype('variable')->end() |
| 91 | 91 | ->validate() |
| 92 | - ->ifTrue(function ($node) { |
|
| 92 | + ->ifTrue(function($node) { |
|
| 93 | 93 | if (!is_array($node)) { |
| 94 | 94 | return true; |
| 95 | 95 | } |
@@ -166,7 +166,7 @@ discard block |
||
| 166 | 166 | ->append($this->addRabbitMqSslOptions()) |
| 167 | 167 | ->append($this->addRabbitMqArgs()) |
| 168 | 168 | ->append($this->addRabbitMqExchange()) |
| 169 | - ->validate()->always(function ($node) { |
|
| 169 | + ->validate()->always(function($node) { |
|
| 170 | 170 | if (empty($node['ssl_options'])) { |
| 171 | 171 | unset($node['ssl_options']); |
| 172 | 172 | } |
@@ -176,7 +176,7 @@ discard block |
||
| 176 | 176 | |
| 177 | 177 | return $node; |
| 178 | 178 | })->end() |
| 179 | - ->validate()->ifTrue(function ($node) { |
|
| 179 | + ->validate()->ifTrue(function($node) { |
|
| 180 | 180 | if (isset($node['ssl_options']) && !$node['ssl']) { |
| 181 | 181 | return true; |
| 182 | 182 | } |