[FORK VERSION FOR NALURI]

• Support Redis Cluster

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
})

Cluster Example

var redis = require('mqemitter-redis')
var mq = redis({
  isCluster: true,
  cluster: [
    {
      port: 12435
      host: '12.34.56.78'
    },
    {
      port: 12435
      host: '12.34.56.79'
    },
    ...
  ]
})

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