TomQueue
A FIFO queue with group-level concurrency support
Install
$ npm install tomqueue
Usage
Dispatcher:
const Dispatcher = Dispatcher;const dispatcher = port: 7446; dispatcherstart; ;
Worker:
const Worker = Worker;const worker = { return ; }; workerstart; { return Promise;}
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 = port: 7446 storage: 'redis' storageOptions: redis: ;