line |
true |
false |
branch |
80
|
0 |
0 |
if ($self->{'_state'} != 0) |
107
|
0 |
0 |
unless my $connection = $self->{'connection'} |
114
|
0 |
0 |
unless my $self = $wself |
115
|
0 |
0 |
if $self->{'_state'} == 1 |
121
|
0 |
0 |
if ($self->{'_state'} == 0) |
158
|
0 |
0 |
if $self->{'_state'} == 0 |
175
|
0 |
0 |
if $@ |
197
|
0 |
0 |
if (my $connection = $self->{'connection'}) |
207
|
0 |
0 |
unless $self->_check_open($failure_cb) |
234
|
0 |
0 |
unless $self->_check_open($failure_cb) |
256
|
0 |
0 |
unless $self->_check_open($failure_cb) |
278
|
0 |
0 |
unless $self->_check_open($failure_cb) |
301
|
0 |
0 |
unless $self->_check_open($failure_cb) |
327
|
0 |
0 |
unless $self->_check_open($failure_cb) |
349
|
0 |
0 |
unless $self->_check_open($failure_cb) |
370
|
0 |
0 |
unless $self->_check_open($failure_cb) |
392
|
0 |
0 |
unless $self->_check_open($failure_cb) |
417
|
0 |
0 |
unless ($self->{'_is_active'}) |
418
|
0 |
0 |
if (defined $args{'on_inactive'}) |
431
|
0 |
0 |
unless defined $header_args |
432
|
0 |
0 |
unless defined $body |
433
|
0 |
0 |
if (defined $ack_cb or defined $nack_cb or defined $return_cb) |
435
|
0 |
0 |
unless $self->{'_is_confirm'} |
439
|
0 |
0 |
if ($self->{'_is_confirm'}) |
442
|
0 |
0 |
if ($return_cb) |
485
|
0 |
0 |
if not ref $v |
486
|
0 |
0 |
if (@prot) |
541
|
0 |
0 |
unless $self->_check_open($failure_cb) |
577
|
0 |
0 |
unless $self->_check_open($failure_cb) |
579
|
0 |
0 |
unless (defined $args{'consumer_tag'}) |
585
|
0 |
0 |
unless ($cons_cbs) |
606
|
0 |
0 |
unless my $cons_cbs = delete $self->{'_consumer_cbs'}{$tag} |
622
|
0 |
0 |
unless $self->_check_open($failure_cb) |
634
|
0 |
0 |
if $frame->method_frame->isa('Net::AMQP::Protocol::Basic::GetEmpty') |
649
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
660
|
0 |
0 |
defined $args{'delivery_tag'} && $args{'delivery_tag'} != 0 ? : |
669
|
0 |
0 |
unless $self->_check_open($failure_cb) |
692
|
0 |
0 |
unless $self->_check_open($failure_cb) |
693
|
0 |
0 |
unless $self->_check_version(0, 9, $failure_cb) |
705
|
0 |
0 |
unless my $me = $wself |
720
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
730
|
0 |
0 |
if (not $args{'nowait'} and $self->_check_version(0, 9)) { } |
749
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
767
|
0 |
0 |
unless $self->_check_open($failure_cb) |
783
|
0 |
0 |
unless $self->_check_open($failure_cb) |
799
|
0 |
0 |
unless $self->_check_open($failure_cb) |
818
|
0 |
0 |
if ($frame->isa('Net::AMQP::Frame::Method')) { } |
820
|
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')) { } |
829
|
0 |
0 |
if ($method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk')) |
843
|
0 |
0 |
if (not $self->_canceled($method_frame->consumer_tag, $frame) and $method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk')) |
852
|
0 |
0 |
unless my $me = $wself |
855
|
0 |
0 |
if (defined(my $tag = $headers->{'_ar_return'})) |
857
|
0 |
0 |
if $cbs |
868
|
0 |
0 |
if (not $self->{'_is_confirm'}) { } |
873
|
0 |
0 |
if ($method_frame->{'multiple'}) { } |
881
|
0 |
0 |
$resp eq 'Ack' ? : |
884
|
0 |
0 |
if (not $cbs = delete $self->{'_publish_cbs'}{$tag}) { } |
|
0 |
0 |
elsif ($cbs->[$cbi]) { } |
901
|
0 |
0 |
$self->{'_is_active'} ? : |
926
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Body') |
931
|
0 |
0 |
if (length $body_payload < $body_size) { } |
933
|
0 |
0 |
unless my $contq = $wcontq |
948
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Header') |
952
|
0 |
0 |
unless $header_frame->isa('Net::AMQP::Protocol::Basic::ContentHeader') |
960
|
0 |
0 |
if ($body_size) { } |
961
|
0 |
0 |
unless my $contq = $wcontq |
986
|
0 |
0 |
if $self->is_open |
999
|
0 |
0 |
if $amaj >= $major or $amaj == $major and $amin >= $minor |
1001
|
0 |
0 |
if $failure_cb |
1007
|
0 |
0 |
if not &in_global_destruction() and $self->is_open |