Task queue mixin for Bee-Queue
npm install moleculer-bee-queueTask queue mixin for Bee-Queue.
``bash`
$ npm install moleculer-bee-queue --save
js
const QueueService = require("moleculer-bee-queue");broker.createService({
name: "task-worker",
mixins: [QueueService()],
queues: {
"mail.send"(job) {
this.logger.info("New job received!", job.data);
job.reportProgress(10);
return this.Promise.resolve({
done: true,
id: job.data.id,
worker: process.pid
});
}
}
});
`Create job in service
js
const QueueService = require("moleculer-bee-queue");broker.createService({
name: "job-maker",
mixins: [QueueService()],
methods: {
sendEmail(data) {
const job = this.createJob("mail.send", payload);
job.on("progress", progress => {
this.logger.info(
Job #${job.id} progress is ${progress}%);
}); job.on("succeeded", res => {
this.logger.info(
Job #${job.id} completed!. Result:, res);
}); job.retries(2).save();
}
}
});
`Test
$ npm test
In development with watching
$ npm run ci
 