From d67f92389b211521b77a5653c4d227a537dfdee5 Mon Sep 17 00:00:00 2001 From: franck cuny Date: Tue, 29 Jun 2010 14:37:57 +0200 Subject: remove delete and processed --- lib/presque/RestQueueHandler.pm | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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(); } -- cgit 1.4.1