about summary refs log tree commit diff
diff options
context:
space:
mode:
-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,);
 }