From 84b5147670347eb26a75c27342d410a580b03de4 Mon Sep 17 00:00:00 2001 From: franck cuny Date: Mon, 28 Jun 2010 10:13:19 +0200 Subject: store value for next delayed job, return info with control status --- lib/presque/ControlHandler.pm | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) (limited to 'lib/presque/ControlHandler.pm') diff --git a/lib/presque/ControlHandler.pm b/lib/presque/ControlHandler.pm index 7feadc8..38bbe89 100644 --- a/lib/presque/ControlHandler.pm +++ b/lib/presque/ControlHandler.pm @@ -15,13 +15,15 @@ __PACKAGE__->asynchronous(1); sub get { my ($self, $queue_name) = @_; - $self->application->redis->get( + $self->application->redis->mget( $self->_queue_stat($queue_name), + $self->_queue_delayed_next($queue_name), sub { - my $status = shift; + my $res = shift; $self->entity( - { queue => $queue_name, - status => $status + { queue => $queue_name, + status => $res->[0], + next_run_after => $res->[1], } ); } -- cgit 1.4.1