summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorfranck cuny <franck@lumberjaph.net>2010-06-29 14:37:57 +0200
committerfranck cuny <franck@lumberjaph.net>2010-06-29 14:37:57 +0200
commitd67f92389b211521b77a5653c4d227a537dfdee5 (patch)
tree10be19c6df4749ab6f09ed2e225ce041df579dc7
parenttests! (diff)
downloadpresque-d67f92389b211521b77a5653c4d227a537dfdee5.tar.gz
remove delete and processed
-rw-r--r--lib/presque/RestQueueHandler.pm3
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/presque/RestQueueHandler.pm b/lib/presque/RestQueueHandler.pm
index 54dffab..650f3bc 100644
--- a/lib/presque/RestQueueHandler.pm
+++ b/lib/presque/RestQueueHandler.pm
@@ -231,12 +231,13 @@ sub _failed_job {
sub _purge_queue {
my ($self, $queue_name) = @_;
- # XXX delete failed && processed
my $lkey = $self->_queue($queue_name);
my $dkey = $self->_queue_delayed($queue_name);
$self->application->redis->del($lkey);
$self->application->redis->del($dkey);
+ $self->application->redis->del($self->_queue_failed($queue_name));
+ $self->application->redis->del($self->_queue_processed($queue_name));
$self->response->code(204);
$self->finish();
}