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 |