diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-07-07 13:51:57 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-07-07 13:51:57 +0200 |
| commit | 3a14d071e5073d1c298008bcaf86f603d88f846c (patch) | |
| tree | d485fb18703c86d1d56b21c7aecf60bd3aed322e /lib/presque/RestQueueHandler.pm | |
| parent | use local redis by default (diff) | |
| download | presque-3a14d071e5073d1c298008bcaf86f603d88f846c.tar.gz | |
delete job
Diffstat (limited to '')
| -rw-r--r-- | lib/presque/RestQueueHandler.pm | 2 |
1 files changed, 2 insertions, 0 deletions
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); } ); |