amqp-pubsub
1.0.0 • Public • Published 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);
});
});
Versions
Current Tags
- VersionDownloads (Last 7 Days)
- 1.0.0
3
Version History
- VersionDownloads (Last 7 Days)
- 1.0.0
3
Package Sidebar
Install
Weekly Downloads