redis-work-queue
v0.1.2
Published
dead-simple distributed work queues in node.js using redis
Downloads
6
Readme
Redis Work Queue
dead-simple distributed work queues in node.js using redis
Status: WIP
Try it: turn on a redis-server and on the same machine run these scripts.
// consumer.js
const Queue = require('redis-work-queue');
const queue = new Queue();
consumer.dispatch('recs_service', { query: 'movies' }, (error, response) => {
console.log(response);
});
// producer.js
const Queue = require('redis-work-queue');
const queue = new Queue();
queue.subscribe('recs_service', (request, reply) => {
// request === { query: 'movies' }
// do some computation/data store access/work
reply(['comedy', 'action', 'sci-fi']); // return output through a callback
});
Usage
The example above is a simple demonstration of using Redis as a message queue to pass RPC-like calls to services.
Installation
npm install --save redis-work-queue
Tests
Running locally, make sure to have a running redis-server on 127.0.0.1:6379
:
$ npm run test:local
Using Docker and Docker-Compose:
$ npm test