6.1.0 • Published 10 months ago
mqemitter-redis v6.1.0
mqemitter-redis 
Redis-powered MQEmitter.
See MQEmitter for the actual API.
Install
$ npm install mqemitter-redis --save
Example
var redis = require('mqemitter-redis')
var mq = redis({
port: 12345,
host: '12.34.56.78',
password: 'my secret',
db: 4
})
var msg = {
topic: 'hello world',
payload: 'or any other fields'
}
mq.on('hello world', function (message, cb) {
// call callback when you are done
// do not pass any errors, the emitter cannot handle it.
cb()
})
// topic is mandatory
mq.emit(msg, function () {
// emitter will never return an error
})
Connection String Example
var redis = require('mqemitter-redis')
var mq = redis({
connectionString: 'redis://:authpassword@127.0.0.1:6380/4'
})
API
MQEmitterRedis(opts)
Creates a new instance of mqemitter-redis. It takes all the same options of ioredis, which is used internally to connect to Redis.
This constructor creates two connections to Redis.
Acknowledgements
Code ported from Ascoltatori.
License
MIT
6.1.0
10 months ago
6.0.0
1 year ago
5.1.0
1 year ago
5.0.0
3 years ago
4.2.0
4 years ago
4.1.0
5 years ago
4.0.3
5 years ago
4.0.2
5 years ago
4.0.1
6 years ago
4.0.0
6 years ago
3.0.0
7 years ago
2.3.0
8 years ago
2.2.0
8 years ago
2.1.0
8 years ago
2.0.0
9 years ago
1.0.1
10 years ago
1.0.0
10 years ago
0.3.0
10 years ago
0.2.0
11 years ago
0.1.2
11 years ago
0.1.1
11 years ago
0.1.0
11 years ago