A priority job queue backed by redis, built for eggjs.
$ npm i egg-delayed-job --save
// {app_root}/config/plugin.js
exports.delayedJob = {
enable: true,
package: 'egg-delayed-job',
};
// {app_root}/config/config.default.js
'use strict';
exports.delayedJob = {
client: {
queuePrefix: 'q',
redis: {
port: 6379,
host: '127.0.0.1',
auth: '',
db: 3,
// see https://github.com/mranney/node_redis#rediscreateclient
options: {
},
},
},
// clients: {}
};
see config/config.default.js for more detail.
app.delayedJob.process('email', (job, done) => {
// send email for this;
email(job.data.to, done);
});
app.delayedJob.create('email', {
title: 'welcome email for justin'
, to: 'gdjyluxiaoyong@gmail.com'
, template: 'welcome-email'
}).save();
form more config please see here
Please open an issue here.