amqp 0.3.0

Synopsis

% CREATE EXTENSION amqp;
CREATE EXTENSION

% SELECT amqp.publish(broker_id, 'amqp.direct', 'foo', 'message');

The pg_amqp package provides the ability for postgres statements to directly publish messages to an AMQP broker.

Insert AMQP broker information (host/port/user/pass) into the amqp.broker table.

A process starts and connects to PostgreSQL and runs:

SELECT amqp.publish(broker_id, 'amqp.direct', 'foo', 'message');

Upon process termination, all broker connections will be torn down. If there is a need to disconnect from a specific broker, one can call:

select amqp.disconnect(broker_id);

which will disconnect from the broker if it is connected and do nothing if it is already disconnected.

This library is stored in an open GitHub repository. Feel free to fork and contribute! Please file bug reports via GitHub Issues.