resque / php-resque

resque-scheduler.php

Spacing +9 added lines, -9 removed lines

@@ -16,7 +16,7 @@ 
 
 $REDIS_BACKEND = getenv('REDIS_BACKEND');
 $REDIS_BACKEND_DB = getenv('REDIS_BACKEND_DB');
-if(!empty($REDIS_BACKEND)) {
+if (!empty($REDIS_BACKEND)) {
 	if (empty($REDIS_BACKEND_DB)) 
 		Resque::setBackend($REDIS_BACKEND);
 	else
@@ -28,33 +28,33 @@ 
 $LOGGING = getenv('LOGGING');
 $VERBOSE = getenv('VERBOSE');
 $VVERBOSE = getenv('VVERBOSE');
-if(!empty($LOGGING) || !empty($VERBOSE)) {
+if (!empty($LOGGING) || !empty($VERBOSE)) {
 	$logLevel = ResqueScheduler_Worker::LOG_NORMAL;
 }
-else if(!empty($VVERBOSE)) {
+else if (!empty($VVERBOSE)) {
 	$logLevel = ResqueScheduler_Worker::LOG_VERBOSE;
 }
 
 // Check for jobs every $interval seconds
 $interval = 5;
 $INTERVAL = getenv('INTERVAL');
-if(!empty($INTERVAL)) {
+if (!empty($INTERVAL)) {
 	$interval = $INTERVAL;
 }
 
 // Load the user's application if one exists
 $APP_INCLUDE = getenv('APP_INCLUDE');
-if($APP_INCLUDE) {
-	if(!file_exists($APP_INCLUDE)) {
-		die('APP_INCLUDE ('.$APP_INCLUDE.") does not exist.\n");
+if ($APP_INCLUDE) {
+	if (!file_exists($APP_INCLUDE)) {
+		die('APP_INCLUDE (' . $APP_INCLUDE . ") does not exist.\n");
 	}
 
 	require_once $APP_INCLUDE;
 }
 
 $PREFIX = getenv('PREFIX');
-if(!empty($PREFIX)) {
-    fwrite(STDOUT, '*** Prefix set to '.$PREFIX."\n");
+if (!empty($PREFIX)) {
+    fwrite(STDOUT, '*** Prefix set to ' . $PREFIX . "\n");
     Resque_Redis::prefix($PREFIX);
 }
 

lib/ResqueScheduler.php

Spacing +6 added lines, -6 removed lines

@@ -108,14 +108,14 @@
      */
     public static function removeDelayed($queue, $class, $args)
     {
-       $destroyed=0;
-       $item=json_encode(self::jobToHash($queue, $class, $args));
-       $redis=Resque::redis();
+       $destroyed = 0;
+       $item = json_encode(self::jobToHash($queue, $class, $args));
+       $redis = Resque::redis();
 
-       foreach($redis->keys('delayed:*') as $key)
+       foreach ($redis->keys('delayed:*') as $key)
        {
-           $key=$redis->removePrefix($key);
-           $destroyed+=$redis->lrem($key,0,$item);
+           $key = $redis->removePrefix($key);
+           $destroyed += $redis->lrem($key, 0, $item);
        }
 
        return $destroyed;

lib/ResqueScheduler/Worker.php

Spacing +4 added lines, -4 removed lines

@@ -73,7 +73,7 @@ 
 	{
 		$item = null;
 		while ($item = ResqueScheduler::nextItemForTimestamp($timestamp)) {
-			$this->log('queueing ' . $item['class'] . ' in ' . $item['queue'] .' [delayed]');
+			$this->log('queueing ' . $item['class'] . ' in ' . $item['queue'] . ' [delayed]');
 			
 			Resque_Event::trigger('beforeDelayedEnqueue', array(
 				'queue' => $item['queue'],
@@ -105,7 +105,7 @@ 
 	 */
 	private function updateProcLine($status)
 	{
-		if(function_exists('setproctitle')) {
+		if (function_exists('setproctitle')) {
 			setproctitle('resque-scheduler-' . ResqueScheduler::VERSION . ': ' . $status);
 		}
 	}
@@ -117,10 +117,10 @@ 
 	 */
 	public function log($message)
 	{
-		if($this->logLevel == self::LOG_NORMAL) {
+		if ($this->logLevel == self::LOG_NORMAL) {
 			fwrite(STDOUT, "*** " . $message . "\n");
 		}
-		else if($this->logLevel == self::LOG_VERBOSE) {
+		else if ($this->logLevel == self::LOG_VERBOSE) {
 			fwrite(STDOUT, "** [" . strftime('%T %Y-%m-%d') . "] " . $message . "\n");
 		}
 	}