Minimalist queue manager based on bull: the awesome Node.js job and message queue.
This module provides a high level API that allow you to re-use shared configurations and instances, as well as reduce the number of redis connections to the minimum by default. Also introduce a convenient "response" promise to easily process jobs result:
let result = await q1.add({
name: 'job1'
}).response;
Create and initialize Queue Manager:
const QueueManager = require('bull-queue-manager').QueueManager;
const qm = new QueueManager(
6379, //redis port
'localhost', //redis host
0, //redis db
{} //redis options (described in https://github.com/luin/ioredis/blob/master/API.md)
);
qm.init();
// also redis connection URL can be used
const qm = new QueueManager('redis://localhost:6379/0', {
// options
});
const q1 = qm.queue('q1');
const q2 = qm.queue('q2');
const q3 = qm.queue('q3');
const q4 = qm.queue('q4');
// optionally override default config
const q5 = qm.queue('q5', 6379, 'redis.instance.com', 1, {});
const q6 = qm.queue('redis://localhost:6379/3', {});
// ...
q1.process(async (job) => {
// ... do something with job.data
// ...
// finally respond something
return {
success: true
};
});
let promise = q1.add({
name: 'job1'
});
let job = await promise; // https://github.com/OptimalBits/bull#job
let promise = q1.add({
name: 'job1'
});
// you can get the response promise here
let result = await promise.response;
// result == { success: true }
qm.shutdown();