diff --git a/lib/Resque.php b/lib/Resque.php index efe7f257..47291899 100644 --- 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.