0

我对 NestJS 和 Bull MQ 有疑问,每当我尝试处理多个作业时,只会执行第一个作业,而不会执行其余作业。

我浏览电子邮件,然后开始像这样处理它们。只有第一个被添加到队列中,而不是其余的。

for (let i = 0; i < mails.length; i++) {
  const mail = mails[i];
  await this.metricsQueue.add(
    'metricsImport',
    {
      date: mail.subject.split(';')[2],
      locationId: Number(mail.subject.split(';')[1]),
      sender: mail.sender,
    },
    { jobId: mail.mailId },
  );
}
4

0 回答 0