在应用程序启动时启动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);
        });

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

但是它不会自动开始处理。

我该怎么办？有什么办法吗？

谢谢

解决方法

重新启动应用程序时，如果当前作业未完成，将具有锁定标志，因此它将暂停。 您可以侦听失败的作业，然后重试。