| line |
true |
false |
branch |
|
24
|
2 |
0 |
if ($args{'TESTING'})
|
|
40
|
0 |
8 |
if exists $args{$name}
|
|
50
|
1 |
5 |
if exists $args{$name}
|
|
68
|
0 |
22 |
if exists $args{$name}
|
|
87
|
1 |
1 |
if $self->{'routing_key'} =~ /%c|%p/
|
|
99
|
1 |
0 |
if $self->{'declare_exchange'}
|
|
102
|
1 |
1 |
unless (eval {
do {
$self->_connect_cached;
$mq->exchange_declare($CHANNEL, $self->{'publish_options'}{'exchange'}, $self->{'exchange_options'}) if $self->{'declare_exchange'};
1
}
})
|
|
116
|
2 |
3 |
if (not $self->{'_is_connected'} or $$ != $self->{'pid'})
|
|
137
|
0 |
2 |
if ($self->{'interpolate_routing_key'})
|
|
155
|
0 |
2 |
unless (eval {
do {
my $mq = $self->_connect_cached;
$mq->publish($CHANNEL, $routing_key, $args{'message'}, $self->{'publish_options'});
$successful = 1;
1
}
})
|
|
170
|
2 |
0 |
if exists $self->{'mq'} and defined $self->{'mq'}
|