2 files changed, 3 insertions, 0 deletions
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);
                     }
                 );