Queue::Q4M::Status - A Q4M Status Object

Queue-Q4M documentation Contained in the Queue-Q4M distribution.

Index

Code Index:

NAME

Top

Queue::Q4M::Status - A Q4M Status Object

SYNPSIS

Top

  my $q4m = Queue::Q4M->connect(...);
  my $status = $q4m->status;

  print "rows written: ", $status->rows_written, "\n";

DESCRIPTION

Top

For a list of possible attributes (such as rows_written) please see the actual q4m manual. This module will parse the output of 

  SHOW ENGINE QUEUE STATUS

and generates accessors for these attributes automatically

METHODS

Top

fetch($dbh)

Given a database handle, creates a Queue::Q4M::Status instance

Queue-Q4M documentation Contained in the Queue-Q4M distribution. 
# $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__