From 1b8c86b95a78bce95ff85bb2972076d7b760331e Mon Sep 17 00:00:00 2001
From: Rishit <rishpandey8097@gmail.com>
Date: Sun, 12 Nov 2023 16:55:38 +0530
Subject: [PATCH] fix: queue name

---
 src/queues/email/email.queue.ts  | 6 ++----
 src/queues/email/email.worker.ts | 3 ++-
 src/types/email.ts               | 1 +
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/queues/email/email.queue.ts b/src/queues/email/email.queue.ts
index 41e9e50..158774c 100644
--- a/src/queues/email/email.queue.ts
+++ b/src/queues/email/email.queue.ts
@@ -1,13 +1,11 @@
-import { Email } from '../../types/email';
+import { EMAIL_QUEUE_IDENTIFIER, Email } from '../../types/email';
 import { Queue, Job } from 'bullmq';
 import { redisConfig } from './redisConfig';
 import EmailWorker from './email.worker';
 import logger from '../../core/logger';
 import { captureException } from '../../core/sentry';
 
-export const EMAIL_QUEUE_IDENTIFIER = 'email-queue';
-
-export const emailQueue = new Queue<Email>('email-queue', {
+export const emailQueue = new Queue<Email>(EMAIL_QUEUE_IDENTIFIER, {
   connection: redisConfig,
 });
 
diff --git a/src/queues/email/email.worker.ts b/src/queues/email/email.worker.ts
index 491fa3d..fff5e0e 100644
--- a/src/queues/email/email.worker.ts
+++ b/src/queues/email/email.worker.ts
@@ -1,7 +1,8 @@
 import { Worker } from 'bullmq';
 import { redisConfig } from './redisConfig';
+import { EMAIL_QUEUE_IDENTIFIER } from '../../types/email';
 
-const EmailWorker = new Worker('email-queue', __dirname + '/email.processor.ts', {
+const EmailWorker = new Worker(EMAIL_QUEUE_IDENTIFIER, __dirname + '/email.processor.ts', {
   connection: redisConfig,
 });
 
diff --git a/src/types/email.ts b/src/types/email.ts
index dfd9e54..62a8bf5 100644
--- a/src/types/email.ts
+++ b/src/types/email.ts
@@ -4,3 +4,4 @@ export interface Email {
   subject: string;
   html: string;
 }
+export const EMAIL_QUEUE_IDENTIFIER = 'email-queue';