diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-07-01 09:18:18 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-07-01 09:18:18 +0200 |
| commit | f0b5053965e250544438b1371ca085ab9235fefa (patch) | |
| tree | 552d6005cb5c1d6a7150e1243a12bfe380066071 | |
| parent | use hashes to store stats (diff) | |
| download | presque-f0b5053965e250544438b1371ca085ab9235fefa.tar.gz | |
don't store anymore the next_run
Diffstat (limited to '')
| -rw-r--r-- | lib/presque/Role/Queue.pm | 11 |
1 files changed, 1 insertions, 10 deletions
diff --git a/lib/presque/Role/Queue.pm b/lib/presque/Role/Queue.pm index 6ac0e8a..fce83e2 100644 --- a/lib/presque/Role/Queue.pm +++ b/lib/presque/Role/Queue.pm @@ -16,17 +16,8 @@ sub push_job { if ($delayed) { $method = 'zadd'; @args = ($queue_name . ':delayed', $delayed, $key); - $self->application->redis->get( - $self->_queue_delayed_next($queue_name), - sub { - my $val = shift; - if (!$val || ($val && $val > $delayed)) { - $self->application->redis->set( - $self->_queue_delayed_next($queue_name), $delayed); - } - } - ); } + $self->application->redis->$method(@args,); } |
