@@ -3,7 +3,7 @@ |
||
| 3 | 3 | { |
| 4 | 4 | public function perform() |
| 5 | 5 | { |
| 6 | - fwrite(STDOUT, 'Start job! -> '); |
|
| 6 | + fwrite(STDOUT, 'Start job! -> '); |
|
| 7 | 7 | sleep(1); |
| 8 | 8 | fwrite(STDOUT, 'Job ended!' . PHP_EOL); |
| 9 | 9 | } |
@@ -195,11 +195,11 @@ |
||
| 195 | 195 | } |
| 196 | 196 | |
| 197 | 197 | /** |
| 198 | - * Fetch a value from the status packet for the job being monitored. |
|
| 199 | - * |
|
| 200 | - * @return mixed False if the status is not being monitored, otherwise the |
|
| 201 | - * requested value from the status packet. |
|
| 202 | - */ |
|
| 198 | + * Fetch a value from the status packet for the job being monitored. |
|
| 199 | + * |
|
| 200 | + * @return mixed False if the status is not being monitored, otherwise the |
|
| 201 | + * requested value from the status packet. |
|
| 202 | + */ |
|
| 203 | 203 | protected function fetch($value = null) |
| 204 | 204 | { |
| 205 | 205 | if (!$this->isTracking()) { |
@@ -36,13 +36,13 @@ |
||
| 36 | 36 | private $paused = false; |
| 37 | 37 | |
| 38 | 38 | /** |
| 39 | - * The primary loop for a worker. |
|
| 40 | - * |
|
| 41 | - * Every $interval (seconds), the scheduled queue will be checked for jobs |
|
| 42 | - * that should be pushed to Resque. |
|
| 43 | - * |
|
| 44 | - * @param int $interval How often to check schedules. |
|
| 45 | - */ |
|
| 39 | + * The primary loop for a worker. |
|
| 40 | + * |
|
| 41 | + * Every $interval (seconds), the scheduled queue will be checked for jobs |
|
| 42 | + * that should be pushed to Resque. |
|
| 43 | + * |
|
| 44 | + * @param int $interval How often to check schedules. |
|
| 45 | + */ |
|
| 46 | 46 | public function work($interval = null) |
| 47 | 47 | { |
| 48 | 48 | if ($interval !== null) { |
@@ -34,8 +34,8 @@ |
||
| 34 | 34 | private static $processPrefix = 'resque'; |
| 35 | 35 | |
| 36 | 36 | /** |
| 37 | - * @var \Psr\Log\LoggerInterface Logging object that impliments the PSR-3 LoggerInterface |
|
| 38 | - */ |
|
| 37 | + * @var \Psr\Log\LoggerInterface Logging object that impliments the PSR-3 LoggerInterface |
|
| 38 | + */ |
|
| 39 | 39 | public $logger; |
| 40 | 40 | |
| 41 | 41 | /** |
@@ -20,7 +20,7 @@ |
||
| 20 | 20 | if (empty($argv[2])) { |
| 21 | 21 | $jobId = \Resque\Resque::enqueue('default', $argv[1], $args, true); |
| 22 | 22 | } else { |
| 23 | - $jobId = \Resque\Resque::enqueue($argv[1], $argv[2], $args, true); |
|
| 23 | + $jobId = \Resque\Resque::enqueue($argv[1], $argv[2], $args, true); |
|
| 24 | 24 | } |
| 25 | 25 | |
| 26 | 26 | echo "Queued job ".$jobId."\n\n"; |