diff options
author | franck cuny <franck@lumberjaph.net> | 2010-06-29 14:37:57 +0200 |
---|---|---|
committer | franck cuny <franck@lumberjaph.net> | 2010-06-29 14:37:57 +0200 |
commit | d67f92389b211521b77a5653c4d227a537dfdee5 (patch) | |
tree | 10be19c6df4749ab6f09ed2e225ce041df579dc7 /lib/presque/RestQueueHandler.pm | |
parent | tests! (diff) | |
download | presque-d67f92389b211521b77a5653c4d227a537dfdee5.tar.gz |
remove delete and processed
Diffstat (limited to '')
-rw-r--r-- | lib/presque/RestQueueHandler.pm | 3 |
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(); } |