redis-clustered-queue
0.0.3 • Public • Published Redis Clustered Queue
Implement a simple queue library with Redis
Example
Publisher:
import Queue from 'redis-clustered-queue';
let myQueue = new Queue('myNiceChannel');
const job = {
name: 'follow',
person1: 'User A',
person2: 'User B'
};
myQueue.submitTask(job);
Subscriber:
import Queue from 'redis-clustered-queue';
let myQueue = new Queue('myNiceChannel');
let i = 0;
myQueue.subscribe(function(job){
i++;
if(i == 3){
myQueue.unSubscribe();
}
console.log(job);
});
API
todo
Implements in different languages
Readme
Keywords
nonePackage Sidebar
Install
npm i redis-clustered-queue
Weekly Downloads