pubsub
wrapper around amqplib to help expediate basic stuffs.
Installation
>$ npm install @package/pubsub
Test
@package/pubsub>$ npm test
Build
if you want to convert @package/pubsub into es5, you can simply run:
@package/pubsub>$ npm run build
API
create_connection(config:Object):AMQPConnection
creates a connection.
Example
import {create_connection} from '@package/pubsub';
// use an alternate port
let conn = yield create_connection({ port : 5673 });init_channel(conn:AMQPConnection, handlers:Object):AMQPChannel
create a channel, assert passed queues in handlers Object into existence and add their callbacks — if any — as consumers.
Example
import {create_connection, init_channel} from '@package/pubsub';
let conn = yield create_connection;
let channel = yield init_channel(conn, {
// assert queue into existence and consume any messages published to it
'queue.name.1' : function* (channel, msg) {
let data = msg.content.toString();
console.log(msg);
// if you want to remove this message from the queue
channel.ack(data);
},
// assert queue into existence only
'queue.name.2' : true
});broadcast(channel:AMQPChannel, queue:String, message:Object[, wait:Number]):Void
broadcast a message to the passed queue.
Example
import {create_connection, init_channel, broadcast} from '@package/pubsub';
let conn = yield create_connection;
let channel = yield init_channel(conn, {
'queue.name.1' : function* (channel, msg) {
let data = JSON.parse(msg.content.toString());
let res = yield doSomethingTo(data);
channel.ack(msg);
// broadcast the new message to a different queue
yield broadcast(channel, 'queue.name.2', res);
},
'queue.name.2' : true
});destroy_queue(conn:AMQPConnection, queue1:String[, queue2:String, ..., , queueN:String]):Void
remove the passed queues, will not throw an Error if a queue does not exist.
Example
import {conn, destroy_queue} from '@package/pubsub';
let conn = yield create_connection;
yield destroy_queue(conn, 'queue.name.1', 'queue.name.2');