Namespace Pollution Mechanism
    Have ideas to improve npm?Join in the discussion! »

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

    4.1.0 • Public • Published

    mqemitter-redis  Build Status

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

    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

    Install

    npm i @eflexsystems/mqemitter-redis

    DownloadsWeekly Downloads

    5

    Version

    4.1.0

    License

    MIT

    Unpacked Size

    11.9 kB

    Total Files

    8

    Last publish

    Collaborators

    • avatar
    • avatar
    • avatar
    • avatar
    • avatar