view release on metacpan or  search on metacpan

README  view on Meta::CPAN

NAME
    AnyMQ::Pg - Use built-in PostgreSQL 'LISTEN' and 'NOTIFY' commands for
    message-passing.

ABOUT
    Enables the use of PostgreSQL as a backend for message queueing
    functionality with AnyMQ.

    Many people are probably unaware that PostgreSQL has a built-in
    asynchronous publish/subscribe mechanism, but it does.

    <http://www.postgresql.org/docs/9.1/interactive/sql-listen.html>

SYNOPSIS
        my $bus = AnyMQ->new_with_traits(
            traits     => ['Pg'],
            dsn        => 'dbname=postgres user=postgres',
            on_connect => sub { ... },
            on_error   => sub { ... },
        );

inc/Module/Install.pm  view on Meta::CPAN

# }

use 5.005;
use strict 'vars';
use Cwd        ();
use File::Find ();
use File::Path ();

use vars qw{$VERSION $MAIN};
BEGIN {
	# All Module::Install core packages now require synchronised versions.
	# This will be used to ensure we don't accidentally load old or
	# different versions of modules.
	# This is not enforced yet, but will be some time in the next few
	# releases once we can make sure it won't clash with custom
	# Module::Install extensions.
	$VERSION = '1.06';

	# Storage for the pseudo-singleton
	$MAIN    = undef;

lib/AnyMQ/Pg.pm  view on Meta::CPAN

AnyMQ::Pg - Use built-in PostgreSQL 'LISTEN' and 'NOTIFY' commands for message-passing.

=cut

our $VERSION = '0.01';

=head1 ABOUT

Enables the use of PostgreSQL as a backend for message queueing functionality with L<AnyMQ>.

Many people are probably unaware that PostgreSQL has a built-in asynchronous publish/subscribe mechanism, but it does.

L<http://www.postgresql.org/docs/9.1/interactive/sql-listen.html>

=head1 SYNOPSIS

    my $bus = AnyMQ->new_with_traits(
        traits     => ['Pg'],
        dsn        => 'dbname=postgres user=postgres',
        on_connect => sub { ... },
        on_error   => sub { ... },