about summary refs log tree commit diff
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();
 }