| line |
true |
false |
branch |
|
166
|
0 |
4 |
if ($observers)
|
|
211
|
4 |
0 |
if ($name =~ m[/queue/]) { }
|
|
|
0 |
0 |
elsif ($name =~ m[/topic/]) { }
|
|
220
|
4 |
0 |
if $dest
|
|
229
|
0 |
275 |
if ($self->shutdown_count)
|
|
238
|
10 |
265 |
unless ($client)
|
|
261
|
0 |
1 |
unless ($name eq 'read' and $number == 0)
|
|
279
|
0 |
4 |
if (my $oref = $self->observers)
|
|
312
|
0 |
150 |
if ($message->has_delay and not $self->pump_frequency)
|
|
325
|
150 |
0 |
if (my $d = $self->get_destination($destination_name) || $self->make_destination($destination_name)) { }
|
|
347
|
6 |
0 |
if (my $d = $self->get_destination($destination_name) || $self->make_destination($destination_name)) { }
|
|
362
|
0 |
0 |
if (my $d = $self->get_destination($destination_name))
|
|
377
|
275 |
0 |
if (my $fn = $handlers{$frame->command}) { }
|
|
380
|
223 |
42 |
if ($frame->command ne 'CONNECT' and $frame->headers and my $receipt = $frame->headers->{'receipt'})
|
|
404
|
100 |
0 |
if ($s and $s->client and $s->client->id eq $client_id) { }
|
|
432
|
4 |
4 |
if ($self->shutdown_count > 1) { }
|
|
434
|
0 |
4 |
if ($self->shutdown_count > 2)
|
|
468
|
0 |
130 |
if $self->shutdown_count > 0
|
|
473
|
130 |
0 |
if (my $client = $subscriber->client) { }
|
|
476
|
130 |
0 |
if ($client->send_frame($msg->create_stomp_frame)) { }
|
|
479
|
100 |
30 |
if ($subscriber->client_ack) { }
|
|
507
|
0 |
0 |
if ($msg->claimed)
|