| blib/lib/POE/Component/MessageQueue/Storage/Generic/DBI.pm | |||
|---|---|---|---|
| Criterion | Covered | Total | % |
| branch | 4 | 38 | 10.5 |
| line | true | false | branch |
|---|---|---|---|
| 74 | 0 | 7 | if (defined $mq_id and $mq_id ne '') |
| 103 | 0 | 7 | unless (defined $server->{'options'}) |
| 137 | 0 | 7 | if (my $err = &catch()) |
| 142 | 7 | 0 | if (defined $dbh) |
| 148 | 0 | 0 | if ($self->cur_server == -1) |
| 168 | 0 | 0 | if ($trying >= $max_retries) |
| 178 | 0 | 0 | if (my $err = &catch()) |
| 198 | 0 | 0 | if @$ids > 0 |
| 217 | 0 | 0 | if defined $val |
| 221 | 0 | 0 | if (defined $mq_id and $mq_id ne '' and defined $args{'claimant'}) |
| 229 | 0 | 0 | if (defined $client_id and defined $self->mq_id and $self->mq_id ne '') |
| 262 | 0 | 0 | unless $self->_wrap('store', sub { my $sth = $self->dbh->prepare("\n\t\t\tINSERT INTO messages (\n\t\t\t\tmessage_id, destination, body, \n\t\t\t\tpersistent, in_use_by, \n\t\t\t\ttimestamp, size,\n\t\t\t\tdeliver_at\n\t\t\t) VALUES (\n\t\t\t\t?, ?, ?, \n\t\t\t\t?, ?, \n\t\t\t\t?, ?,\n\t\t\t\t?\n\t\t\t)\n\t\t"); $sth->execute($m->id, $m->destination, $m->body, $m->persistent, $self->_in_use_by($m->claimant), $m->timestamp, $m->size, $m->deliver_at); } ) |
| 266 | 0 | 0 | if $callback |
| 288 | 0 | 0 | @$messages > 0 ? : |
| 320 | 0 | 0 | if (my $message = $_[0]) |
| 344 | 0 | 0 | if $callback |
| 372 | 0 | 0 | if $callback |
| 385 | 0 | 0 | if $callback |
| 397 | 0 | 0 | if $callback |