about summary refs log tree commit diff
path: root/lib/presque/Role/Queue.pm
diff options
context:
space:
mode:
authorfranck cuny <franck@lumberjaph.net>2010-07-01 09:18:18 +0200
committerfranck cuny <franck@lumberjaph.net>2010-07-01 09:18:18 +0200
commitf0b5053965e250544438b1371ca085ab9235fefa (patch)
tree552d6005cb5c1d6a7150e1243a12bfe380066071 /lib/presque/Role/Queue.pm
parentuse hashes to store stats (diff)
downloadpresque-f0b5053965e250544438b1371ca085ab9235fefa.tar.gz
don't store anymore the next_run
Diffstat (limited to '')
-rw-r--r--lib/presque/Role/Queue.pm11
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,);
 }