POE::Component::MessageQueue::Storage::DBI -- A storage engine that uses DBI
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;
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).
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
To install POE::Component::MessageQueue, copy and paste the appropriate command in to your terminal.
cpanm
cpanm POE::Component::MessageQueue
CPAN shell
perl -MCPAN -e shell install POE::Component::MessageQueue
For more information on module installation, please visit the detailed CPAN module installation guide.