| line |
true |
false |
branch |
|
134
|
0 |
0 |
unless ($_rabbitmq_connection_for_connection_id{$conn_id}) |
|
148
|
0 |
0 |
if ($retry > 0) |
|
165
|
0 |
0 |
if ($@) { } |
|
177
|
0 |
0 |
unless ($connected) |
|
183
|
0 |
0 |
unless ($channel_number) |
|
194
|
0 |
0 |
if ($@) |
|
214
|
0 |
0 |
unless (defined $_reply_to_queues_for_connection_id_function_name{$conn_id}) |
|
219
|
0 |
0 |
unless ($_reply_to_queues_for_connection_id_function_name{$conn_id}{$function_name}) |
|
235
|
0 |
0 |
unless (defined $_results_caches_for_connection_id_function_name{$conn_id}) |
|
240
|
0 |
0 |
unless (defined $_results_caches_for_connection_id_function_name{$conn_id}{$function_name}) |
|
265
|
0 |
0 |
unless (defined $queue_name) |
|
277
|
0 |
0 |
$lazy_queue ? : |
|
283
|
0 |
0 |
if ($@) |
|
288
|
0 |
0 |
if ($declare_and_bind_exchange) |
|
304
|
0 |
0 |
if ($@) |
|
315
|
0 |
0 |
unless (defined $queue_name) |
|
330
|
0 |
0 |
unless (defined $queue_name) |
|
347
|
0 |
0 |
unless ($routing_key) |
|
351
|
0 |
0 |
unless ($payload) |
|
358
|
0 |
0 |
if ($@) |
|
366
|
0 |
0 |
if ($extra_options) |
|
374
|
0 |
0 |
if ($extra_props) |
|
380
|
0 |
0 |
if ($@) |
|
396
|
0 |
0 |
unless (exists $RABBITMQ_PRIORITIES{$priority}) |
|
416
|
0 |
0 |
unless ($correlation_id) |
|
428
|
0 |
0 |
unless ($delivery_tag) |
|
434
|
0 |
0 |
unless ($payload_json) |
|
441
|
0 |
0 |
if ($@ or not $payload or ref $payload ne ref {}) |
|
446
|
0 |
0 |
if ($payload->{'task'} ne $function_name) |
|
462
|
0 |
0 |
if ($reply_to) |
|
467
|
0 |
0 |
if ($error_message) { } |
|
509
|
0 |
0 |
if ($@) |
|
517
|
0 |
0 |
if ($@) |
|
560
|
0 |
0 |
if ($@) |
|
568
|
0 |
0 |
if (exists $results_cache->{$celery_job_id}) { } |
|
589
|
0 |
0 |
unless ($correlation_id) |
|
594
|
0 |
0 |
if ($correlation_id eq $celery_job_id) { } |
|
610
|
0 |
0 |
unless ($message) |
|
616
|
0 |
0 |
unless ($correlation_id) |
|
620
|
0 |
0 |
if ($correlation_id ne $celery_job_id) |
|
628
|
0 |
0 |
unless ($payload_json) |
|
635
|
0 |
0 |
if ($@ or not $payload or ref $payload ne ref {}) |
|
640
|
0 |
0 |
if ($payload->{'task_id'} ne $celery_job_id) |
|
646
|
0 |
0 |
if ($payload->{'status'} eq 'SUCCESS') { } |
|
|
0 |
0 |
elsif ($payload->{'status'} eq 'FAILURE') { } |
|
676
|
0 |
0 |
unless (defined $args) |
|
680
|
0 |
0 |
unless (ref $args eq ref {}) |
|
708
|
0 |
0 |
if ($publish_results) { } |
|
738
|
0 |
0 |
if ($@) |