Добрый день.
Есть письма, которые отправляет пользователь.
При отправке, каждое письмо помещается в базу данных, где ей присваевается номер письма и время добавления в базу.
В отправке писем, есть лимит на минуту, то есть, пользователь не может отправить больше 100 писем в минуту. Если количество писем превышено, то следующее письмо станет в очередь и отправится через минуту и так далее.
Вот часть моего кода.
queue.create(`email`, {
title: `HELLO KUE 1`,
id: Math.floor(Math.random() * Math.floor(100)),
to: 'tj@learnboost.com',
})
.save((err) => {
if (!err) console.log(`error`);
}
);
Но я не понимаю, как правильно вызвать
queue.process
Вызывать
setInterval каждую минуту? Я думал, что у kue есть механизм для этого?
Подскажите пожалуйста, как это можно сделать с помощью
kue