gistfile1.pl

use POE;
use POE::Component::MessageQueue;
use POE::Component::MessageQueue::Storage::DBI;
use strict;
 
# For mysql:
my $DB_DSN      = 'DBI:Pg:database=pocomq;hostname=127.0.0.1';
my $DB_USERNAME = 'pocomq';
my $DB_PASSWORD = '12345';
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;