diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-28 10:13:19 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-28 10:13:19 +0200 |
| commit | 84b5147670347eb26a75c27342d410a580b03de4 (patch) | |
| tree | 71302d475e90f899516782014912129a2a468628 /lib/presque/ControlHandler.pm | |
| parent | add POD; fix queue size when null (diff) | |
| download | presque-84b5147670347eb26a75c27342d410a580b03de4.tar.gz | |
store value for next delayed job, return info with control status
Diffstat (limited to '')
| -rw-r--r-- | lib/presque/ControlHandler.pm | 10 |
1 files changed, 6 insertions, 4 deletions
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], } ); } |