| line |
true |
false |
branch |
|
142
|
0 |
0 |
unless ($_rabbitmq_connection_for_connection_id{$conn_id}) |
|
156
|
0 |
0 |
if ($retry > 0) |
|
173
|
0 |
0 |
if ($@) { } |
|
185
|
0 |
0 |
unless ($connected) |
|
191
|
0 |
0 |
unless ($channel_number) |
|
202
|
0 |
0 |
if ($@) |
|
222
|
0 |
0 |
unless (defined $_reply_to_queues_for_connection_id_function_name{$conn_id}) |
|
227
|
0 |
0 |
unless ($_reply_to_queues_for_connection_id_function_name{$conn_id}{$function_name}) |
|
243
|
0 |
0 |
unless (defined $_results_caches_for_connection_id_function_name{$conn_id}) |
|
248
|
0 |
0 |
unless (defined $_results_caches_for_connection_id_function_name{$conn_id}{$function_name}) |
|
273
|
0 |
0 |
unless (defined $queue_name) |
|
285
|
0 |
0 |
$lazy_queue ? : |
|
291
|
0 |
0 |
if ($@) |
|
296
|
0 |
0 |
if ($declare_and_bind_exchange) |
|
312
|
0 |
0 |
if ($@) |
|
323
|
0 |
0 |
unless (defined $queue_name) |
|
338
|
0 |
0 |
unless (defined $queue_name) |
|
355
|
0 |
0 |
unless ($routing_key) |
|
359
|
0 |
0 |
unless ($payload) |
|
366
|
0 |
0 |
if ($@) |
|
374
|
0 |
0 |
if ($extra_options) |
|
382
|
0 |
0 |
if ($extra_props) |
|
388
|
0 |
0 |
if ($@) |
|
404
|
0 |
0 |
unless (exists $RABBITMQ_PRIORITIES{$priority}) |
|
424
|
0 |
0 |
unless ($correlation_id) |
|
436
|
0 |
0 |
unless ($delivery_tag) |
|
442
|
0 |
0 |
unless ($payload_json) |
|
449
|
0 |
0 |
if ($@ or not $payload or ref $payload ne ref {}) |
|
454
|
0 |
0 |
if ($payload->{'task'} ne $function_name) |
|
470
|
0 |
0 |
if ($reply_to) |
|
475
|
0 |
0 |
if ($error_message) { } |
|
517
|
0 |
0 |
if ($@) |
|
525
|
0 |
0 |
if ($@) |
|
568
|
0 |
0 |
if ($@) |
|
576
|
0 |
0 |
if (exists $results_cache->{$celery_job_id}) { } |
|
597
|
0 |
0 |
unless ($correlation_id) |
|
602
|
0 |
0 |
if ($correlation_id eq $celery_job_id) { } |
|
618
|
0 |
0 |
unless ($message) |
|
624
|
0 |
0 |
unless ($correlation_id) |
|
628
|
0 |
0 |
if ($correlation_id ne $celery_job_id) |
|
636
|
0 |
0 |
unless ($payload_json) |
|
643
|
0 |
0 |
if ($@ or not $payload or ref $payload ne ref {}) |
|
648
|
0 |
0 |
if ($payload->{'task_id'} ne $celery_job_id) |
|
654
|
0 |
0 |
if ($payload->{'status'} eq 'SUCCESS') { } |
|
|
0 |
0 |
elsif ($payload->{'status'} eq 'FAILURE') { } |
|
684
|
0 |
0 |
unless (defined $args) |
|
688
|
0 |
0 |
unless (ref $args eq ref {}) |
|
716
|
0 |
0 |
if ($publish_results) { } |
|
746
|
0 |
0 |
if ($@) |