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