amqp-pubsub

Minimalist abstraction layer for amqp publish/subscribe implementations

Installation

npm install amqp-pubsub

Usage

Publisher

var amqp = require('amqp');
var pubsub = require('amqp-pubsub');
 
var connection = amqp.createConnection({ host: "localhost" });
 
connection.on('ready', function() {
  var pubsubClient = pubsub(connection, 'amqp-pubsub-example');
  pubsubClient.publish({ test : 'hello world'});
});
 

Subscriber

var amqp = require('amqp');
var pubsub = require('../');
 
var connection = amqp.createConnection({ host: "localhost" });
 
connection.on('ready', function() {
  var pubsubClient = pubsub(connection, 'amqp-pubsub-example');
 
  pubsubClient.subscribe(function(message) {
    console.log(message);
  });
});