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);
 	}

lib/Redis.php

Spacing +2 added lines, -2 removed lines

@@ -198,12 +198,12 @@
 
 		// Check the URI scheme
 		$validSchemes = array('redis', 'tcp');
-		if (isset($parts['scheme']) && ! in_array($parts['scheme'], $validSchemes)) {
+		if (isset($parts['scheme']) && !in_array($parts['scheme'], $validSchemes)) {
 			throw new InvalidArgumentException("Invalid DSN. Supported schemes are " . implode(', ', $validSchemes));
 		}
 
 		// Allow simple 'hostname' format, which `parse_url` treats as a path, not host.
-		if (! isset($parts['host']) && isset($parts['path'])) {
+		if (!isset($parts['host']) && isset($parts['path'])) {
 			$parts['host'] = $parts['path'];
 			unset($parts['path']);
 		}

lib/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()) {

Spacing +2 added lines, -2 removed lines

@@ -64,7 +64,7 @@ 
 			'started' => time(),
 			'result'  => null,
 		);
-		Resque::redis()->set((string) $status, json_encode($statusPacket));
+		Resque::redis()->set((string)$status, json_encode($statusPacket));
 
 		return $status;
 	}
@@ -97,7 +97,7 @@ 
 	 */
 	public function update($status, $result = null)
 	{
-		$status = (int) $status;
+		$status = (int)$status;
 
 		if (!$this->isTracking()) {
 			return;

lib/Worker/SchedulerWorker.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/Worker/ResqueWorker.php

Indentation +2 added lines, -2 removed lines

@@ -34,8 +34,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;
 
 	/**

Spacing +1 added lines, -1 removed lines

@@ -532,7 +532,7 @@
 			exec('WMIC path win32_process get Processid,Commandline | findstr resque | findstr /V findstr', $cmdOutput);
 			foreach ($cmdOutput as $line) {
 				$line = preg_replace('/\s+/m', ' ', $line);
-				list(,,$pids[]) = explode(' ', trim($line), 3);
+				list(,, $pids[]) = explode(' ', trim($line), 3);
 			}
 		} else {
 			exec('ps -A -o pid,args | grep [r]esque', $cmdOutput);

demo/queue.php

Indentation +1 added lines, -1 removed lines

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

Spacing +2 added lines, -2 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-if(empty($argv[1])) {
+if (empty($argv[1])) {
 	die('Specify the name of a job to add. e.g, php queue.php PHP_Job');
 }
 
@@ -23,4 +23,4 @@ 
         $jobId = \Resque\Resque::enqueue($argv[1], $argv[2], $args, true);
 }
 
-echo "Queued job ".$jobId."\n\n";
+echo "Queued job " . $jobId . "\n\n";

demo/check_status.php

Spacing +5 added lines, -5 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-if(empty($argv[1])) {
+if (empty($argv[1])) {
 	die('Specify the ID of a job to monitor the status of.');
 }
 
@@ -12,12 +12,12 @@ 
 //\Resque\Resque::setBackend('redis://user:pass@a.host.name:3432/2');
 
 $status = new \Resque\Job\Status($argv[1]);
-if(!$status->isTracking()) {
+if (!$status->isTracking()) {
 	die("Resque is not tracking the status of this job.\n");
 }
 
-echo "Tracking status of ".$argv[1].". Press [break] to stop.\n\n";
-while(true) {
-	fwrite(STDOUT, "Status of ".$argv[1]." is: ".$status->get()."\n");
+echo "Tracking status of " . $argv[1] . ". Press [break] to stop.\n\n";
+while (true) {
+	fwrite(STDOUT, "Status of " . $argv[1] . " is: " . $status->get() . "\n");
 	sleep(1);
 }

lib/Scheduler.php

Spacing +2 added lines, -2 removed lines

@@ -73,7 +73,7 @@ 
 		$redis = Resque::redis();
 		$redis->rpush('delayed:' . $timestamp, json_encode($item));
 
-		$redis->zadd('delayed_queue_schedule', $timestamp, (string) $timestamp);
+		$redis->zadd('delayed_queue_schedule', $timestamp, (string)$timestamp);
 	}
 
 	/**
@@ -184,7 +184,7 @@ 
 
 		if ($redis->llen($key) == 0) {
 			$redis->del($key);
-			$redis->zrem('delayed_queue_schedule', (string) $timestamp);
+			$redis->zrem('delayed_queue_schedule', (string)$timestamp);
 		}
 	}