@eflexsystems/mqemitter-redis
TypeScript icon, indicating that this package has built-in type declarations

5.0.0-1 • Public • Published

mqemitter-redis  ci

Redis-powered MQEmitter.

See MQEmitter for the actual API.

js-standard-style

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

Package Sidebar

Install

npm i @eflexsystems/mqemitter-redis

Weekly Downloads

20

Version

5.0.0-1

License

MIT

Unpacked Size

14.7 kB

Total Files

10

Last publish

Collaborators

  • eflex
  • jakesjews
  • rrglomsk
  • nevans54
  • josephdickens87