line |
l |
!l |
condition |
481
|
0 |
0 |
delete $args->{'weight'} || 0 |
484
|
0 |
0 |
$args->{'headers'} || {} |
543
|
0 |
0 |
delete $args{'on_consume'} || sub {
}
|
544
|
0 |
0 |
delete $args{'on_cancel'} || sub {
}
|
545
|
0 |
0 |
delete $args{'no_ack'} // 1 |
620
|
0 |
0 |
delete $args{'no_ack'} // 1 |
836
|
0 |
0 |
$cons_cbs && $cons_cbs->[0] || sub {
}
|
853
|
0 |
0 |
$ret->{'header'}->headers || {} |
859
|
0 |
0 |
$me->{'on_return'} || $me->{'connection'}{'on_return'} || sub {
}
|
902
|
0 |
0 |
$self->{$cbname} || $self->{'connection'}{$cbname} || sub {
}
|
976
|
0 |
0 |
delete $args{'on_success'} || sub {
}
|
977
|
0 |
0 |
delete $args{'on_failure'} || sub {
die @_;
}
|
line |
l |
!l&&r |
!l&&!r |
condition |
156
|
0 |
0 |
0 |
$frame ||= $self->_close_frame |
433
|
0 |
0 |
0 |
defined $ack_cb or defined $nack_cb |
|
0 |
0 |
0 |
defined $ack_cb or defined $nack_cb or defined $return_cb |
523
|
0 |
0 |
0 |
$self->{'connection'}{'_body_max'} || length $body |
820
|
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') |
829
|
0 |
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk') |
859
|
0 |
0 |
0 |
$onret_cb ||= $me->{'on_return'} || $me->{'connection'}{'on_return'} || sub {
}
|
999
|
0 |
0 |
0 |
$amaj >= $major or $amaj == $major and $amin >= $minor |