Запустить процесс Bull Queue при запуске приложения

Я создаю очередь и добавляю задание в свой API.

Я также начинаю обрабатывать свою работу по вызову API.

const newQueue = createQueue(queueName, opts);

newQueue.add('JokesJob', data, options);

newQueue.process('JokesJob', async (job) => {
            data.jobId = job.id;
            await work(queueName, job.id, 'http://localhost:4045');
            job.progress(5);
        });

Но когда я перезапускаю свое приложение. Очередь должна начать обработку по расписанию заданий.

Но он не запускает обработку автоматически.

Что я могу сделать? Там в любом случае?

Спасибо


person xMayank    schedule 06.10.2020    source источник


Ответы (1)


Когда вы перезапускаете приложение, ваше текущее задание будет заблокировано, если оно не выполнено, поэтому оно остановится. Вы можете прослушать неудачное задание и повторить попытку.

person Samir Sayyad    schedule 10.12.2020