Unleash awesomeness. Private packages, team management tools, and powerful integrations. Get started with npm Orgs »

mess-queue

1.2.2 • Public • Published

Nodejs - redis stream queue

Stream queue using redis with driver node_redis

NPM version Downloads

Installation

# Get the latest stable release of rsq 
$ npm install rsq
  or
$ yarn install rsq

Usage Example

const Queue = require('rsq')
const queue = new Queue()
 
// streams working concurently
queue.newTopic('log').newStream('mysql').newStream('otherStream')
 
 
// regist handle
queue.registHandle(
  [
    { topic: 'log', stream: 'mysql', type: 'create' },
    // { topic: 'log', stream: ['mysql', 'outherStream'], type: ['create', 'otherType'] },
  ],
  (message, done) => {
    setTimeout(() => {
      console.log('LOG CREATE: ' + JSON.stringify(message))
      done()
    }, 200)
  }
)
 
queue.registHandle(
  [
    { topic: 'log', stream: 'mysql', type: 'remove' },
  ],
  (message, done) => {
    console.log('LOG REMOVE: ' + JSON.stringify(message))
    done()
  }
)
 
// listen error
queue.on('error', (err, message) => {
  throw err
})
 
// push message
for (let i = 0; i < 10; i++) {
  queue.push({
    topic: 'log',
    stream: 'mysql',
    type: (Math.random() < 0.5)? 'create' : 'remove',
    payload: { data: 'something' + i }
  }, (err) => {
    if (err) throw err
  })
}

APIs

const queue = new Queue([name], [config])
const topic = queue.newTopic(name, [config])
 
topic.newStream(name, [config])
queue.registHandle([{ topic, stream, type }], handle)
queue.push(message, callback)
object.on(event, handle)
object.emit(event, data)

Options object properties

Property Default Description
redisClient redis client Client node redis, default create with redisConfig
redisConfig null Default options redis client
priority 0 0-timeout, 1-imediate, 2-nextTick
expires 2 day Expires key redis (secends)

see redisConfig node_redis

install

npm i mess-queue

Downloadsweekly downloads

1

version

1.2.2

license

MIT

homepage

github.com

repository

Gitgithub

last publish

collaborators

  • avatar
Report a vulnerability