diff --git a/mail-service/src/service/dynamicConsumer.js b/mail-service/src/service/dynamicConsumer.js index ca8d12e..9f8b746 100644 --- a/mail-service/src/service/dynamicConsumer.js +++ b/mail-service/src/service/dynamicConsumer.js @@ -299,6 +299,11 @@ async function processEmailTask(task, topic) { 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) { console.error('Error sending email:', err, 'task:', task);