From 44940e84bc93adda75f52ea644d00db461ae9a63 Mon Sep 17 00:00:00 2001 From: Dan Rahmel Date: Fri, 13 Mar 2015 15:36:24 -0700 Subject: [PATCH] Restored whitespace --- lib/Resque.php | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/Resque.php b/lib/Resque.php index 09e01669..47291899 100644 --- a/lib/Resque.php +++ b/lib/Resque.php @@ -147,7 +147,7 @@ public static function dequeue($queue, $items = Array()) * Remove specified queue * * @param string $queue The name of the queue to remove. - * @return integer number of deleted items + * @return integer Number of deleted items */ public static function removeQueue($queue) { @@ -277,12 +277,12 @@ private static function removeItems($queue, $items = Array()) $originalQueue = 'queue:'. $queue; $tempQueue = $originalQueue. ':temp:'. time(); $requeueQueue = $tempQueue. ':requeue'; - + // move each item from original queue to temp queue and process it $finished = false; while (!$finished) { $string = self::redis()->rpoplpush($originalQueue, self::redis()->getPrefix() . $tempQueue); - + if (!empty($string)) { if(self::matchItem($string, $items)) { self::redis()->rpop($tempQueue); @@ -307,7 +307,7 @@ private static function removeItems($queue, $items = Array()) // remove temp queue and requeue queue self::redis()->del($requeueQueue); self::redis()->del($tempQueue); - + return $counter; }