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