@@ -222,7 +222,7 @@ discard block |
||
| 222 | 222 | */ |
| 223 | 223 | public function getQueues() |
| 224 | 224 | { |
| 225 | - return \array_map(function ($queue) { |
|
| 225 | + return \array_map(function($queue) { |
|
| 226 | 226 | return new Queue($queue); |
| 227 | 227 | }, \Resque::queues()); |
| 228 | 228 | } |
@@ -241,7 +241,7 @@ discard block |
||
| 241 | 241 | */ |
| 242 | 242 | public function getWorkers() |
| 243 | 243 | { |
| 244 | - return \array_map(function ($worker) { |
|
| 244 | + return \array_map(function($worker) { |
|
| 245 | 245 | return new Worker($worker); |
| 246 | 246 | }, \Resque_Worker::all()); |
| 247 | 247 | } |
@@ -106,7 +106,7 @@ |
||
| 106 | 106 | $output->writeln(\sprintf('Starting worker <info>%s</info>', $process->getCommandLine())); |
| 107 | 107 | |
| 108 | 108 | if ($input->getOption('foreground')) { |
| 109 | - $process->run(function ($type, $buffer) use ($output) { |
|
| 109 | + $process->run(function($type, $buffer) use ($output) { |
|
| 110 | 110 | $output->write($buffer); |
| 111 | 111 | }); |
| 112 | 112 | } // else we recompose and display the worker id |
@@ -106,7 +106,7 @@ |
||
| 106 | 106 | $output->writeln(\sprintf('Starting worker <info>%s</info>', $process->getCommandLine())); |
| 107 | 107 | |
| 108 | 108 | if ($input->getOption('foreground')) { |
| 109 | - $process->run(function ($type, $buffer) use ($output) { |
|
| 109 | + $process->run(function($type, $buffer) use ($output) { |
|
| 110 | 110 | $output->write($buffer); |
| 111 | 111 | }); |
| 112 | 112 | } // else we recompose and display the worker id |