| line |
true |
false |
branch |
|
83
|
0 |
0 |
if ($self->{'_state'} != 0) |
|
110
|
0 |
0 |
unless my $connection = $self->{'connection'} |
|
117
|
0 |
0 |
unless my $self = $wself |
|
118
|
0 |
0 |
if $self->{'_state'} == 1 |
|
124
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
161
|
0 |
0 |
if $self->{'_state'} == 0 |
|
178
|
0 |
0 |
if $@ |
|
200
|
0 |
0 |
if (my $connection = $self->{'connection'}) |
|
210
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
237
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
259
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
281
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
304
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
330
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
352
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
373
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
395
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
420
|
0 |
0 |
unless ($self->{'_is_active'}) |
|
421
|
0 |
0 |
if (defined $args{'on_inactive'}) |
|
434
|
0 |
0 |
unless defined $header_args |
|
435
|
0 |
0 |
unless defined $body |
|
436
|
0 |
0 |
if (defined $ack_cb or defined $nack_cb or defined $return_cb) |
|
438
|
0 |
0 |
unless $self->{'_is_confirm'} |
|
442
|
0 |
0 |
if ($self->{'_is_confirm'}) |
|
445
|
0 |
0 |
if ($return_cb) |
|
488
|
0 |
0 |
if not ref $v |
|
489
|
0 |
0 |
if (@prot) |
|
544
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
580
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
582
|
0 |
0 |
unless (defined $args{'consumer_tag'}) |
|
588
|
0 |
0 |
unless ($cons_cbs) |
|
609
|
0 |
0 |
unless my $cons_cbs = delete $self->{'_consumer_cbs'}{$tag} |
|
625
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
637
|
0 |
0 |
if $frame->method_frame->isa('Net::AMQP::Protocol::Basic::GetEmpty') |
|
652
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
|
663
|
0 |
0 |
defined $args{'delivery_tag'} && $args{'delivery_tag'} != 0 ? : |
|
672
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
695
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
696
|
0 |
0 |
unless $self->_check_version(0, 9, $failure_cb) |
|
708
|
0 |
0 |
unless my $me = $wself |
|
723
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
|
733
|
0 |
0 |
if (not $args{'nowait'} and $self->_check_version(0, 9)) { } |
|
752
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
|
770
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
786
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
802
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
821
|
0 |
0 |
if ($frame->isa('Net::AMQP::Frame::Method')) { } |
|
823
|
0 |
0 |
if ($method_frame->isa('Net::AMQP::Protocol::Channel::Close')) { } |
|
|
0 |
0 |
elsif ($self->{'_state'} != 2) { } |
|
|
0 |
0 |
elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::Deliver')) { } |
|
|
0 |
0 |
elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk') or $method_frame->isa('Net::AMQP::Protocol::Basic::Cancel')) { } |
|
|
0 |
0 |
elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::Return')) { } |
|
|
0 |
0 |
elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::Ack') or $method_frame->isa('Net::AMQP::Protocol::Basic::Nack')) { } |
|
|
0 |
0 |
elsif ($method_frame->isa('Net::AMQP::Protocol::Channel::Flow')) { } |
|
832
|
0 |
0 |
if ($method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk')) |
|
846
|
0 |
0 |
if (not $self->_canceled($method_frame->consumer_tag, $frame) and $method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk')) |
|
855
|
0 |
0 |
unless my $me = $wself |
|
858
|
0 |
0 |
if (defined(my $tag = $headers->{'_ar_return'})) |
|
860
|
0 |
0 |
if $cbs |
|
871
|
0 |
0 |
if (not $self->{'_is_confirm'}) { } |
|
876
|
0 |
0 |
if ($method_frame->{'multiple'}) { } |
|
884
|
0 |
0 |
$resp eq 'Ack' ? : |
|
887
|
0 |
0 |
if (not $cbs = delete $self->{'_publish_cbs'}{$tag}) { } |
|
|
0 |
0 |
elsif ($cbs->[$cbi]) { } |
|
904
|
0 |
0 |
$self->{'_is_active'} ? : |
|
929
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Body') |
|
934
|
0 |
0 |
if (length $body_payload < $body_size) { } |
|
936
|
0 |
0 |
unless my $contq = $wcontq |
|
951
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Header') |
|
955
|
0 |
0 |
unless $header_frame->isa('Net::AMQP::Protocol::Basic::ContentHeader') |
|
963
|
0 |
0 |
if ($body_size) { } |
|
964
|
0 |
0 |
unless my $contq = $wcontq |
|
989
|
0 |
0 |
if $self->is_open |
|
1002
|
0 |
0 |
if $amaj >= $major or $amaj == $major and $amin >= $minor |
|
1004
|
0 |
0 |
if $failure_cb |
|
1010
|
0 |
0 |
if not &in_global_destruction() and $self->is_open |