resque / php-resque

demo/job.php

Indentation +1 added lines, -1 removed lines

@@ -3,7 +3,7 @@
 {
 	public function perform()
 	{
-        fwrite(STDOUT, 'Start job! -> ');
+		fwrite(STDOUT, 'Start job! -> ');
 		sleep(1);
 		fwrite(STDOUT, 'Job ended!' . PHP_EOL);
 	}

demo/queue.php

Indentation +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
 if (empty($argv[2])) {
 	$jobId = Resque::enqueue('default', $argv[1], $args, true);
 } else {
-        $jobId = Resque::enqueue($argv[1], $argv[2], $args, true);	
+		$jobId = Resque::enqueue($argv[1], $argv[2], $args, true);	
 }
 
 echo "Queued job ".$jobId."\n\n";

lib/ResqueScheduler/Worker.php

Indentation +7 added lines, -7 removed lines

@@ -36,13 +36,13 @@
 	private $paused = false;
 
 	/**
-	* The primary loop for a worker.
-	*
-	* Every $interval (seconds), the scheduled queue will be checked for jobs
-	* that should be pushed to Resque.
-	*
-	* @param int $interval How often to check schedules.
-	*/
+	 * The primary loop for a worker.
+	 *
+	 * Every $interval (seconds), the scheduled queue will be checked for jobs
+	 * that should be pushed to Resque.
+	 *
+	 * @param int $interval How often to check schedules.
+	 */
 	public function work($interval = null)
 	{
 		if ($interval !== null) {

lib/Resque/Worker.php

Indentation +2 added lines, -2 removed lines

@@ -18,8 +18,8 @@
 	private static $processPrefix = 'resque';
 
 	/**
-	* @var Psr\Log\LoggerInterface Logging object that impliments the PSR-3 LoggerInterface
-	*/
+	 * @var Psr\Log\LoggerInterface Logging object that impliments the PSR-3 LoggerInterface
+	 */
 	public $logger;
 
 	/**

lib/Resque/Job/Status.php

Indentation +5 added lines, -5 removed lines

@@ -195,11 +195,11 @@
 	}
 
 	/**
-	* Fetch a value from the status packet for the job being monitored.
-	*
-	* @return mixed False if the status is not being monitored, otherwise the
-	*  requested value from the status packet.
-	*/
+	 * Fetch a value from the status packet for the job being monitored.
+	 *
+	 * @return mixed False if the status is not being monitored, otherwise the
+	 *  requested value from the status packet.
+	 */
 	protected function fetch($value = null)
 	{
 		if (!$this->isTracking()) {