@@ -188,7 +188,7 @@ discard block |
||
| 188 | 188 | |
| 189 | 189 | /** |
| 190 | 190 | * @param Job $job |
| 191 | - * @return mixed |
|
| 191 | + * @return integer |
|
| 192 | 192 | */ |
| 193 | 193 | public function removedDelayed(Job $job) |
| 194 | 194 | { |
@@ -301,7 +301,7 @@ discard block |
||
| 301 | 301 | } |
| 302 | 302 | |
| 303 | 303 | /** |
| 304 | - * @return mixed |
|
| 304 | + * @return integer |
|
| 305 | 305 | */ |
| 306 | 306 | public function getNumberOfDelayedJobs() |
| 307 | 307 | { |
@@ -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 | } |
@@ -45,7 +45,7 @@ |
||
| 45 | 45 | */ |
| 46 | 46 | public function getQueues() |
| 47 | 47 | { |
| 48 | - return \array_map(function ($queue) { |
|
| 48 | + return \array_map(function($queue) { |
|
| 49 | 49 | return new Queue($queue); |
| 50 | 50 | }, $this->worker->queues()); |
| 51 | 51 | } |
@@ -132,7 +132,7 @@ |
||
| 132 | 132 | |
| 133 | 133 | // if foreground, we redirect output |
| 134 | 134 | if ($input->getOption('foreground')) { |
| 135 | - $process->run(function ($type, $buffer) use ($output) { |
|
| 135 | + $process->run(function($type, $buffer) use ($output) { |
|
| 136 | 136 | $output->write($buffer); |
| 137 | 137 | }); |
| 138 | 138 | } // 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 |