diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-30 14:47:22 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-30 14:47:22 +0200 |
| commit | ce9cd75d412aafd066dd22268dc8b8528976842c (patch) | |
| tree | 9fe9049d89988d8d35b7d22e4eaf112fa9a156c2 | |
| parent | remove the next_run_after (diff) | |
| download | presque-ce9cd75d412aafd066dd22268dc8b8528976842c.tar.gz | |
processed and failed are stored in a hash
| -rw-r--r-- | lib/presque/JobQueueHandler.pm | 25 |
1 files changed, 16 insertions, 9 deletions
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, + } + ); } ); } |