| line |
true |
false |
branch |
|
138
|
0 |
0 |
unless $rabbit_hostname |
|
139
|
0 |
0 |
unless $rabbit_options |
|
149
|
0 |
0 |
unless $mq->connect($rabbit_hostname, $rabbit_options) |
|
156
|
0 |
0 |
unless my $from_queue = $options->{'from_queue'} |
|
157
|
0 |
0 |
if (defined $options->{'publish_options'} and not defined $options->{'routing_key'}) |
|
160
|
0 |
0 |
defined $options->{'routing_key'} ? : |
|
162
|
0 |
0 |
unless my $handler = $options->{'handler'} |
|
174
|
0 |
0 |
if ($ignore_errors) { } |
|
181
|
0 |
0 |
if ($success and $self->_check_messages($messages, $processed_messages, $options->{'batch'})) { } |
|
182
|
0 |
0 |
if ($publish) |
|
211
|
0 |
0 |
if ($msg) { } |
|
215
|
0 |
0 |
if (&Net::AMQP::RabbitMQ::Batch::time() - $batch_activity_ts > $opts->{'timeout'}) { } |
|
255
|
0 |
0 |
if (ref $processed_messages ne 'ARRAY') |
|
259
|
0 |
0 |
if (not $options->{'ignore_size'} and scalar @$messages != scalar @$processed_messages) |