coresync/ads-marketing
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

sleep

Browse Source
This commit is contained in:
romantarkin 2025-08-18 15:04:39 +05:00
parent 0c337bdbe6
commit 500e6f5725
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
mail-service/src/service/dynamicConsumer.js
View File

@ -299,6 +299,11 @@ async function processEmailTask(task, topic) {
console.log(`[DynamicConsumer] DeliveryLog updated for campaign ${task.campaignId}, subscriber ${task.subscriberId}`); console.log(`[DynamicConsumer] DeliveryLog updated for campaign ${task.campaignId}, subscriber ${task.subscriberId}`);
// Засыпаем на 60 секунд после отправки
console.log(`[DynamicConsumer] Sleeping for 60 seconds after sending email to ${task.email}`);
await new Promise(resolve => setTimeout(resolve, 60000));
console.log(`[DynamicConsumer] Woke up after 60 seconds sleep`);
} catch (err) { } catch (err) {
console.error('Error sending email:', err, 'task:', task); console.error('Error sending email:', err, 'task:', task);