From f0b5053965e250544438b1371ca085ab9235fefa Mon Sep 17 00:00:00 2001 From: franck cuny Date: Thu, 1 Jul 2010 09:18:18 +0200 Subject: don't store anymore the next_run --- lib/presque/Role/Queue.pm | 11 +---------- 1 file changed, 1 insertion(+), 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,); } -- cgit 1.4.1