File Coverage

blib/lib/Queue/Q4M/Status.pm

Criterion	Covered	Total	%
statement	12	32	37.5
branch	0	4	0.0
condition	0	3	0.0
subroutine	4	6	66.6
pod	1	1	100.0
total	17	46	36.9

# $Id$

package Queue::Q4M::Status;
use strict;
use DBI;
use Carp();

sub fetch {
    # Black magic. Since I don't know if the parameters will be the same
    # for every future release of Q4M, I'll just create a cached
    # anonymous class via moose. Wicked!

    my $class = shift;
    my $dbh   = shift || Carp::confess("Q4M requires a database handle");

    my $sth = $dbh->prepare( "SHOW ENGINE QUEUE STATUS" );

    $sth->execute();
    my %attributes;

    my ($dummy1, $dummy2, $status);
    $sth->bind_columns(\($dummy1, $dummy2, $status));
    $sth->fetchrow_arrayref;
    $sth->finish;

    # now parse the status
    { no strict 'refs';
        foreach my $line (split(/\r?\n/, $status)) {
            next unless $line =~ /^([\w_]+)\s+(\d+)$/;

            my ($name, $value) = ($1, $2);
            if (! defined &{$class.'::'.$name}) {
                *{$class.'::'.$name} = sub { shift->{$name} };
            }
            $attributes{$1} = $2;
        }
    }
    return bless {%attributes}, $class;
}

1;

__END__