line |
l |
!l |
condition |
483
|
0 |
0 |
delete $args->{'weight'} || 0 |
486
|
0 |
0 |
$args->{'headers'} || {} |
545
|
0 |
0 |
delete $args{'on_consume'} || sub {
}
|
546
|
0 |
0 |
delete $args{'on_cancel'} || sub {
}
|
547
|
0 |
0 |
delete $args{'no_ack'} // 1 |
622
|
0 |
0 |
delete $args{'no_ack'} // 1 |
838
|
0 |
0 |
$cons_cbs && $cons_cbs->[0] || sub {
}
|
855
|
0 |
0 |
$ret->{'header'}->headers || {} |
861
|
0 |
0 |
$me->{'on_return'} || $me->{'connection'}{'on_return'} || sub {
}
|
904
|
0 |
0 |
$self->{$cbname} || $self->{'connection'}{$cbname} || sub {
}
|
978
|
0 |
0 |
delete $args{'on_success'} || sub {
}
|
979
|
0 |
0 |
delete $args{'on_failure'} || sub {
die @_;
}
|
line |
l |
!l&&r |
!l&&!r |
condition |
158
|
0 |
0 |
0 |
$frame ||= $self->_close_frame |
435
|
0 |
0 |
0 |
defined $ack_cb or defined $nack_cb |
|
0 |
0 |
0 |
defined $ack_cb or defined $nack_cb or defined $return_cb |
525
|
0 |
0 |
0 |
$self->{'connection'}{'_body_max'} || length $body |
822
|
0 |
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk') or $method_frame->isa('Net::AMQP::Protocol::Basic::Cancel') |
|
0 |
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Basic::Ack') or $method_frame->isa('Net::AMQP::Protocol::Basic::Nack') |
831
|
0 |
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk') |
861
|
0 |
0 |
0 |
$onret_cb ||= $me->{'on_return'} || $me->{'connection'}{'on_return'} || sub {
}
|
1001
|
0 |
0 |
0 |
$amaj >= $major or $amaj == $major and $amin >= $minor |