From ce9cd75d412aafd066dd22268dc8b8528976842c Mon Sep 17 00:00:00 2001 From: franck cuny Date: Wed, 30 Jun 2010 14:47:22 +0200 Subject: processed and failed are stored in a hash --- lib/presque/JobQueueHandler.pm | 25 ++++++++++++++++--------- 1 file changed, 16 insertions(+), 9 deletions(-) (limited to 'lib') diff --git a/lib/presque/JobQueueHandler.pm b/lib/presque/JobQueueHandler.pm index f108277..fb76037 100644 --- a/lib/presque/JobQueueHandler.pm +++ b/lib/presque/JobQueueHandler.pm @@ -22,16 +22,23 @@ sub get { $key, sub { my $size = shift; - $self->application->redis->mget( - $processed, - $failed, + $self->application->redis->hget( + $self->_queue_processed, + $queue_name, sub { - my $res = shift; - $self->entity( - { queue_name => $queue_name, - job_count => $size || 0, - job_processed => $res->[0] || 0, - job_failed => $res->[1] || 0, + my $processed = shift; + $self->application->redis->hget( + $self->_queue_failed, + $queue_name, + sub { + my $failed = shift; + $self->entity( + { queue_name => $queue_name, + job_count => $size || 0, + job_failed => $failed || 0, + job_processed => $processed || 0, + } + ); } ); } -- cgit 1.4.1