bull plugin for egg framework
$ npm i egg-bull --save
// {app_root}/config/plugin.js
exports.bull = {
enable: true,
package: 'egg-bull',
};
// {app_root}/config/config.unittest.js
exports.bull = {
default: {
redis: {
host: '127.0.0.1',
port: 6379,
}
},
clients: {
TestQueue: {topic: 'test'},
},
app: true,
agent: false
};
see config/config.unittest.js for more detail.
app.bull.get('TestQueue').add({ message: 'hi bull' });
app.bull.get('TestQueue').process(function(job) {
assert(job.data.message === 'hi bull');
done();
});
see bull home page for more details
Please open an issue here.