NAME

Swarmage::Queue::DBI - DBI Based Queue For Swarmage

SYNOPSIS

# To use from POE:
use Swarmage::Queue::DBI;
use Swarmage::Queue::DBI::Generic;

my $queue = Swarmage::Queue::DBI::Generic->new(
  connect_info => [
    'dbi:Pg:dbname=swarmage',
    $username,
    $password,
    { RaiseError => 1, AutoCommit => 1 }
  ]
);

METHODS

new

enqueue

dequeue

poll_wait

prepare_db

pump