David Snopek > POE-Component-MessageQueue-0.2.12 > POE::Component::MessageQueue::Storage::DBI

Download:
POE-Component-MessageQueue-0.2.12.tar.gz

Dependencies

Annotate this POD

CPAN RT

New  4
Open  2
View/Report Bugs
Source   Latest Release: POE-Component-MessageQueue-0.3001

NAME ^

POE::Component::MessageQueue::Storage::DBI -- A storage engine that uses DBI

SYNOPSIS ^

  use POE;
  use POE::Component::MessageQueue;
  use POE::Component::MessageQueue::Storage::DBI;
  use strict;

  # For mysql:
  my $DB_DSN      = 'DBI:mysql:database=perl_mq';
  my $DB_USERNAME = 'perl_mq';
  my $DB_PASSWORD = 'perl_mq';
  my $DB_OPTIONS  = undef;

  POE::Component::MessageQueue->new({
    storage => POE::Component::MessageQueue::Storage::DBI->new({
      dsn      => $DB_DSN,
      username => $DB_USERNAME,
      password => $DB_PASSWORD,
      options  => $DB_OPTIONS
    })
  });

  POE::Kernel->run();
  exit;

DESCRIPTION ^

A storage engine that uses DBI. All messages stored with this backend are persisted.

Performance is increased greatly by wrapping this engine in POE::Component::MessageQueue::Storage::Throttled at the expense of being slower to persist messages.

This module is really just POE::Component::MessageQueue::Storage::Generic with POE::Component::MessageQueue::Storage::Generic::DBI. See the documentation for those modules for more information (primarily POE::Component::MessageQueue::Storage::Generic::DBI).

CONSTRUCTOR PARAMETERS ^

dsn => SCALAR
username => SCALAR
password => SCALAR
options => SCALAR
mq_id => SCALAR

SEE ALSO ^

POE::Component::MessageQueue, POE::Component::MessageQueue::Storage, DBI

Other storage engines:

POE::Component::MessageQueue::Storage::Memory, POE::Component::MessageQueue::Storage::BigMemory, POE::Component::MessageQueue::Storage::FileSystem, POE::Component::MessageQueue::Storage::Generic, POE::Component::MessageQueue::Storage::Generic::DBI, POE::Component::MessageQueue::Storage::Throttled, POE::Component::MessageQueue::Storage::Complex, POE::Component::MessageQueue::Storage::Default

syntax highlighting: