resque / php-resque

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

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

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

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