amqpevents
0.0.2 • Public • Published amqpevents
Event emitter using amqp as a data store and a topic exchange
Usage
var events = require('amqpevents');
var publisher = events
.publisher('location')
.connect('amqp://localhost')
.event('location.locked')
.event('location.lost');
var subscriber = events
.consume(publisher)
.listener(console.info)
.pattern('location.*')
.subscribe();
publisher.publish('location.lost', { lat: 33.23, lng: 150.11 });
Versions
Current Tags
- VersionDownloads (Last 7 Days)
- 0.0.2
1
Version History
- VersionDownloads (Last 7 Days)
- 0.0.2
1
Package Sidebar
Install
Weekly Downloads