Merge pull request chrisboulton#237 from drahmel/master

Added remove_queue command from Resque
sgoyal77 · May 13, 2015 · df69e89 · df69e89
2 parents 941d49c + 44940e8
commit df69e89
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/lib/Resque.php b/lib/Resque.php
@@ -143,6 +143,19 @@ 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
+	 */
+	public static function removeQueue($queue)
+	{
+	    $num = self::removeList($queue);
+	    self::redis()->srem('queues', $queue);
+	    return $num;
+	}
+
 	/**
 	 * Pop an item off the end of the specified queues, using blocking list pop,
 	 * decode it and return it.