TomQueue

A FIFO queue with group-level concurrency support

Install

$ npm install tomqueue

Usage

Dispatcher:

const Dispatcher = require('tomqueue').Dispatcher;
const dispatcher = new Dispatcher({
  port: 7446
});

dispatcher.start();

setTimeout(function () {
  const payload = {
    channel: 'abc',
    baseRev: 67,
    changeset: ''
  };
  dispatcher.send(payload).then((res) => {
    console.log(res);
  }).catch(console.error);
}, 3000);

Worker:

const Worker = require('tomqueue').Worker;
const worker = new Worker({
  handler(payload) {
    return processChangeset(payload);
  }
});

worker.start();

function processChangeset(data) {
  return Promise.resolve(data);
}

Payload

The method Dispatcher#send() receives a payload object, which must contain a channel property representing which channel the payload should be sent to.

Storage

TomQueue supports two storages. The default storage is memory based. To switch to the redis-based storage, set storage option to "redis":

const dispatcher = new Dispatcher({
  port: 7446,
  storage: 'redis',
  storageOptions: {
    redis: new Redis()
  }
});