added notification queue consumer

src/observers/notification-queue-consumer.ts

@@ -0,0 +1,17 @@
+import { Processor, WorkerHost } from '@nestjs/bullmq';
+import { Injectable, Logger } from '@nestjs/common';
+import { Job } from 'bullmq';
+
+@Injectable()
+@Processor('n')
+export class NotificationQueueConsumer extends WorkerHost {
+  readonly logger = new Logger(NotificationQueueConsumer.name);
+
+  constructor() {
+    super();
+  }
+
+  async process(job: Job) {
+    this.logger.debug(job?.id);
+  }
+}

src/observers/observers.module.ts

@@ -31,6 +31,7 @@ import { SmsQueueConsumer } from './sms-queue-consumer';
 import { SmtpService } from './smtp.service';
 import { SwaggerService } from './swagger.service';
 import { WebAdminConsoleService } from './web-admin-console.service';
+import { NotificationQueueConsumer } from './notification-queue-consumer';
 
 @Module({
   providers: [
@@ -45,6 +46,7 @@ import { WebAdminConsoleService } from './web-admin-console.service';
     MiddlewareAllService,
     EmailQueueConsumer,
     SmsQueueConsumer,
+    NotificationQueueConsumer,
   ],
   imports: [
     ConfigurationsModule,