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