From 3a14d071e5073d1c298008bcaf86f603d88f846c Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Wed, 7 Jul 2010 13:51:57 +0200
Subject: delete job

---
 lib/presque/RestQueueBatchHandler.pm | 1 +
 lib/presque/RestQueueHandler.pm      | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/lib/presque/RestQueueBatchHandler.pm b/lib/presque/RestQueueBatchHandler.pm
index abdbe5e..311f223 100644
--- a/lib/presque/RestQueueBatchHandler.pm
+++ b/lib/presque/RestQueueBatchHandler.pm
@@ -62,6 +62,7 @@ sub _get_jobs_from_queue {
                     $value,
                     sub {
                         my $job = shift;
+                        $self->application->redis->del($value);
                         push @$keys, $value;
                         push @$jobs, $job;
                         if (++$pos > ($batch_size - 1)) {
diff --git a/lib/presque/RestQueueHandler.pm b/lib/presque/RestQueueHandler.pm
index 92542ba..0f919cd 100644
--- a/lib/presque/RestQueueHandler.pm
+++ b/lib/presque/RestQueueHandler.pm
@@ -62,6 +62,7 @@ sub _get_job_from_delay_queue {
         $k,
         sub {
             my $job = shift;
+            $self->application->redis->del($k);
             $self->_finish_get($queue_name, $job, $k);
         }
     );
@@ -81,6 +82,7 @@ sub _get_job_from_queue {
                     $value,
                     sub {
                         my $job = shift;
+                        $self->application->redis->del($value);
                         $self->_finish_get($queue_name, $job, $value);
                     }
                 );
-- 
cgit v1.2.3