plus.queue
Simple redis-based Queue and scalable Workers
Queue and Worker Example
const redis = ; const Queue Worker QueueFactory = ; const redisClient = redis; const testQueue = ; testQueuetestQueuetestQueuetestQueuetestQueue testQueue testQueuetestQueuetestQueue const testWorker = WorkertestQueue { console; return myCsutomInfoForSubscriber: job myCsutomDataForSubscriber: job ;} scale: 1 // quantity of handler, parallel interval: 1000 // ask interval in ms; // prints// 1// 2// 3// 4// 5// 6 // 7// 8// 10// 11// 12 testWorker; testWorkerstart;
Queue Example
testQueue
Queue Factory (sugar)
const redisClient = redis; const testQueueFactory = ; const testQueue = ; testQueue // ....