line |
l |
!l |
condition |
484
|
0 |
0 |
delete $args->{'weight'} || 0 |
487
|
0 |
0 |
$args->{'headers'} || {} |
546
|
0 |
0 |
delete $args{'on_consume'} || sub {
}
|
547
|
0 |
0 |
delete $args{'on_cancel'} || sub {
}
|
548
|
0 |
0 |
delete $args{'no_ack'} // 1 |
623
|
0 |
0 |
delete $args{'no_ack'} // 1 |
839
|
0 |
0 |
$cons_cbs && $cons_cbs->[0] || sub {
}
|
856
|
0 |
0 |
$ret->{'header'}->headers || {} |
862
|
0 |
0 |
$me->{'on_return'} || $me->{'connection'}{'on_return'} || sub {
}
|
905
|
0 |
0 |
$self->{$cbname} || $self->{'connection'}{$cbname} || sub {
}
|
979
|
0 |
0 |
delete $args{'on_success'} || sub {
}
|
980
|
0 |
0 |
delete $args{'on_failure'} || sub {
die @_;
}
|
line |
l |
!l&&r |
!l&&!r |
condition |
159
|
0 |
0 |
0 |
$frame ||= $self->_close_frame |
436
|
0 |
0 |
0 |
defined $ack_cb or defined $nack_cb |
|
0 |
0 |
0 |
defined $ack_cb or defined $nack_cb or defined $return_cb |
526
|
0 |
0 |
0 |
$self->{'connection'}{'_body_max'} || length $body |
823
|
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') |
832
|
0 |
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk') |
862
|
0 |
0 |
0 |
$onret_cb ||= $me->{'on_return'} || $me->{'connection'}{'on_return'} || sub {
}
|
1002
|
0 |
0 |
0 |
$amaj >= $major or $amaj == $major and $amin >= $minor |