From 2dd26da19b43e51f68a7dbdb8874c29844fe4f90 Mon Sep 17 00:00:00 2001 From: Philipp Dormann Date: Wed, 11 Dec 2024 18:41:22 +0100 Subject: [PATCH] re-enable logs --- src/queues/email.queue.ts | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/queues/email.queue.ts b/src/queues/email.queue.ts index e8ef139..d82970b 100644 --- a/src/queues/email.queue.ts +++ b/src/queues/email.queue.ts @@ -32,9 +32,9 @@ const transporter = createTransport({ port: config.smtp.port, auth: { user: config.smtp.user, - pass: config.smtp.pass - } -}) + pass: config.smtp.pass, + }, +}); const worker = new Worker( QUEUE_NAME, @@ -46,7 +46,7 @@ const worker = new Worker( subject: job.data.subject, text: job.data.text, html: job.data.html, - }) + }); }, { connection, @@ -61,7 +61,7 @@ const worker = new Worker( const queueEvents = new QueueEvents(QUEUE_NAME, { connection }); worker.on("completed", (job) => { - // console.log(`Email job ${job.id} completed`); + console.log(`Email job ${job.id} completed`); }); worker.on("failed", (job, error) => { @@ -69,7 +69,7 @@ worker.on("failed", (job, error) => { }); queueEvents.on("waiting", ({ jobId }) => { - // console.log(`Job ${jobId} is waiting`) + console.log(`Job ${jobId} is waiting`); }); process.on("SIGTERM", async () => {