mqemitter-mongodb ![Build Status](https://travis-ci.org/mcollina/mqemitter-mongodb.png)
MongoDB powered MQEmitter.
See MQEmitter for the actual
API.
![js-standard-style](https://raw.githubusercontent.com/feross/standard/master/badge.png)
Install
$ npm install mqemitter-mongodb --save
Example
var mongodb = require('mqemitter-mongodb')
var mq = mongodb({
url: 'mongodb://127.0.0.1/mqemitter?auto_reconnect'
})
var msg = {
topic: 'hello world',
payload: 'or any other fields'
}
mq.on('hello world', function (message, cb) {
cb()
})
mq.emit(msg, function () {
})
API
MQEmitterMongoDB([opts])
Create a new instance of mqemitter-mongodb.
Options:
url
: a mongodb endpoint urldatabase
: a mongodb database name, by default it comes from the urimongo
: options for mongodb clientdb
: a db instance of mongodb (instead of url)
Acknowledgements
Code ported from Ascoltatori.
License
MIT