diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-25 14:51:52 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-25 14:51:52 +0200 |
| commit | 4cc0ce236115054fab2e2d288220199024f5a467 (patch) | |
| tree | dd539a42551cc774b90ee9652ba75f939e79138a /lib/presque/JobQueueHandler.pm | |
| parent | alter order for arguments in methods call (diff) | |
| download | presque-4cc0ce236115054fab2e2d288220199024f5a467.tar.gz | |
add POD; fix queue size when null
Diffstat (limited to 'lib/presque/JobQueueHandler.pm')
| -rw-r--r-- | lib/presque/JobQueueHandler.pm | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/lib/presque/JobQueueHandler.pm b/lib/presque/JobQueueHandler.pm index 6bc9f8f..62ad8da 100644 --- a/lib/presque/JobQueueHandler.pm +++ b/lib/presque/JobQueueHandler.pm @@ -22,6 +22,7 @@ sub get { $key, sub { my $size = shift; + warn "ici avec size!\n"; $self->application->redis->mget( $processed, $failed, @@ -29,9 +30,9 @@ sub get { my $res = shift; $self->entity( { queue_name => $queue_name, - job_count => $size, - job_processed => $res->[0], - job_failed => $res->[1], + job_count => $size || 0, + job_processed => $res->[0] || 0, + job_failed => $res->[1] || 0, } ); } |