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 /lib/presque/Role/Queue | |
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,); } |