5.1.0 • Published 4 days ago
mqemitter-redis v5.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
5.1.0
4 days ago
5.0.0
2 years ago
4.2.0
2 years ago
4.1.0
3 years ago
4.0.3
4 years ago
4.0.2
4 years ago
4.0.1
4 years ago
4.0.0
4 years ago
3.0.0
6 years ago
2.3.0
6 years ago
2.2.0
7 years ago
2.1.0
7 years ago
2.0.0
8 years ago
1.0.1
8 years ago
1.0.0
8 years ago
0.3.0
9 years ago
0.2.0
9 years ago
0.1.2
10 years ago
0.1.1
10 years ago
0.1.0
10 years ago