line |
true |
false |
branch |
121
|
0 |
2 |
unless $self->connected
|
123
|
1 |
1 |
unless $self->_channel_exists($channel)
|
132
|
1 |
7 |
unless $self->connected
|
141
|
1 |
9 |
unless $self->connectable
|
151
|
1 |
5 |
unless $self->connected
|
153
|
0 |
5 |
unless $self->_channel_exists($channel)
|
155
|
0 |
5 |
unless $self->_queue_exists($queue)
|
163
|
1 |
4 |
unless $options->{'no_ack'}
|
169
|
0 |
4 |
exists $options->{'consumer_tag'} ? :
|
176
|
1 |
5 |
unless $self->connected
|
178
|
3 |
2 |
unless defined $consumer_tag and length $consumer_tag
|
181
|
1 |
1 |
unless $self->_has_queue
|
192
|
0 |
2 |
unless $self->connected
|
201
|
0 |
6 |
unless $self->connected
|
203
|
0 |
6 |
unless $self->_channel_exists($channel)
|
212
|
0 |
1 |
unless $self->connected
|
214
|
0 |
1 |
unless $self->_channel_exists($channel)
|
223
|
1 |
3 |
unless $self->connected
|
225
|
1 |
2 |
unless $self->_channel_exists($channel)
|
228
|
0 |
2 |
if $messages
|
237
|
1 |
3 |
unless $self->connected
|
239
|
1 |
2 |
unless $self->_channel_exists($channel)
|
242
|
1 |
1 |
unless $messages
|
255
|
1 |
3 |
unless $self->connected
|
257
|
1 |
2 |
unless $self->_channel_exists($channel)
|
260
|
1 |
1 |
unless $messages
|
269
|
0 |
9 |
unless $self->connected
|
271
|
0 |
9 |
unless $self->_channel_exists($channel)
|
273
|
0 |
9 |
unless $self->_queue_exists($queue)
|
277
|
1 |
8 |
unless defined $message
|
291
|
0 |
9 |
unless $self->connected
|
293
|
0 |
9 |
unless $self->_channel_exists($channel)
|
295
|
0 |
9 |
unless $self->_queue_exists($queue)
|
297
|
0 |
9 |
unless $self->_exchange_exists($exchange)
|
303
|
3 |
6 |
if ($pattern =~ /\#/ or $pattern =~ /\*/) { }
|
304
|
2 |
1 |
if ($pattern =~ /\#/) { }
|
|
1 |
0 |
elsif ($pattern =~ /\*/) { }
|
327
|
0 |
12 |
unless $self->connected
|
329
|
0 |
12 |
unless $self->_channel_exists($channel)
|
331
|
2 |
10 |
if ($options->{'passive'}) { }
|
334
|
0 |
2 |
unless defined $queue and length $queue and $self->_queue_exists($queue)
|
339
|
0 |
10 |
unless defined $queue and length $queue
|
341
|
9 |
1 |
unless $self->_queue_exists($queue)
|
344
|
9 |
3 |
unless wantarray
|
347
|
0 |
3 |
$self->queue && $self->queue eq $queue ? :
|
356
|
0 |
1 |
unless $self->connected
|
358
|
0 |
1 |
unless $self->_channel_exists($channel)
|
367
|
0 |
0 |
unless $self->connected
|
369
|
0 |
0 |
unless $self->_channel_exists($channel)
|
371
|
0 |
0 |
unless $self->_queue_exists($queue)
|
373
|
0 |
0 |
unless $self->_exchange_exists($exchange)
|
375
|
0 |
0 |
unless $self->_binding_exists($routing_key)
|
385
|
1 |
10 |
unless $self->connected
|
387
|
0 |
10 |
unless $self->_channel_exists($channel)
|
390
|
2 |
8 |
if ($messages)
|
402
|
0 |
9 |
unless ($exchange)
|
406
|
0 |
9 |
unless $self->_exchange_exists($exchange)
|
412
|
13 |
5 |
if ($routing_key =~ /$pattern/)
|
413
|
0 |
13 |
if $self->debug
|
429
|
1 |
5 |
unless $self->connected
|
432
|
0 |
5 |
unless defined $queue
|
436
|
1 |
4 |
unless defined $message
|
456
|
2 |
13 |
if exists $new_args->{$key}
|