diff options
-rw-r--r-- | lib/presque/JobQueueHandler.pm | 7 | ||||
-rw-r--r-- | lib/presque/RestQueueBatchHandler.pm | 22 | ||||
-rw-r--r-- | lib/presque/WorkerHandler.pm | 7 |
3 files changed, 30 insertions, 6 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, } ); } diff --git a/lib/presque/RestQueueBatchHandler.pm b/lib/presque/RestQueueBatchHandler.pm index adbfe06..30008b8 100644 --- a/lib/presque/RestQueueBatchHandler.pm +++ b/lib/presque/RestQueueBatchHandler.pm @@ -148,3 +148,25 @@ sub _create_job { } 1; +__END__ + +=head1 NAME + +presque::RestQueueBatchHandler + +=head1 SYNOPSIS + + # insert a list of jobs + curl -H 'Content-Type: application/json' -X POST "http://localhost:5000/qb/foo" -d '{jobs:["key":"value"], ["key2":"value2"]}' + + # fetch some jobs + curl http://localhost:5000/qb/foo + +=head1 DESCRIPTION + +=head1 METHODS + +=head2 get + +=head2 post + diff --git a/lib/presque/WorkerHandler.pm b/lib/presque/WorkerHandler.pm index 4399ddf..dcb6acf 100644 --- a/lib/presque/WorkerHandler.pm +++ b/lib/presque/WorkerHandler.pm @@ -71,9 +71,10 @@ sub _get_stats_for_worker { 'failed:' . $worker_id, sub { my $res = shift; - my $desc = JSON::decode_json(shift @$res); - $desc->{processed} = shift @$res; - $desc->{failed} = shift @$res; + my $desc = {}; + $desc = JSON::decode_json(shift @$res) if $res->[0]; + $desc->{processed} = $res->[1] || 0; + $desc->{failed} = $res->[2] || 0; $self->entity($desc); } ); |