diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/presque/RestQueueBatchHandler.pm | 1 | ||||
| -rw-r--r-- | lib/presque/RestQueueHandler.pm | 2 |
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); } ); |