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