diff options
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,); } |