Я хотел бы знать, как выполнить код в моей функции myCustomMethod через Queue / Bull.Это правильный способ сделать это?
. / Models / Sport.js
export async function myCustomMethod(type, req)
{
console.log("This method should be executed via the Queue / Bull");
let computationResult = true;
return computationResult;
}
cronCustomFile.js
import { myCustomMethod } from './models/Sport.js';
cron.schedule('*/5 * * * * *', () =>
{
var battleRoyaleQueue = new Queue('battle_royale_queue');
console.log('Checking live events every 5 seconds');
battleRoyaleQueue.process(function (job, done)
{
try
{
console.log('Processing via battle_royale_queue');
myCustomMethod('live-events');
done();
}
catch (err)
{
console.log(err.message);
}
});
return true;
});
Версия Bull "bull": "^ 3.6.0"
Дополнительная информация
Похоже, что задания не добавляются в очередь или не обрабатываются,
Ссылка
https://github.com/OptimalBits/bull