fix: queue name

genzyy · Nov 12, 2023 · 1b8c86b · 1b8c86b
1 parent 0557d53
commit 1b8c86b
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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
@@ -4,3 +4,4 @@ export interface Email {
   subject: string;
   html: string;
 }
+export const EMAIL_QUEUE_IDENTIFIER = 'email-queue';