javascript - 在应用程序启动时启动 Bull Queue 进程

Question

我正在创建队列并在我的 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);
        });

但是当我重新启动我的应用程序时。队列应按作业计划开始处理。

但它不会自动开始处理。

我能做些什么？有什么办法吗？

谢谢

Answer 1

当您重新启动应用程序时，如果您当前的工作没有完成，您当前的工作就会有锁定标志，所以它会停止。您可以侦听失败的作业并重试。