clear intervals before shutdown

bcgov · Dec 5, 2024 · 60668d4 · 60668d4
1 parent 6962547
commit 60668d4
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/queue/notification-queue-consumer.ts b/src/queue/notification-queue-consumer.ts
@@ -299,6 +299,7 @@ export class NotificationQueueConsumer
     }
   }
 
+  private timeouts = [];
   async process(job: Job) {
     this.logger.debug(job?.id);
     const notification = await this.notificationsService.findOne(
@@ -319,12 +320,17 @@ export class NotificationQueueConsumer
             updated: new Date(),
           });
         }, 300000);
+        this.timeouts.push(hbTimeout);
         await this.broadcastToSubscriberChunk(notification, job);
-        clearTimeout(hbTimeout);
+        this.timeouts.splice(this.timeouts.indexOf(hbTimeout), 1);
+        clearInterval(hbTimeout);
     }
   }
 
   async beforeApplicationShutdown() {
+    for (const t of this.timeouts) {
+      clearInterval(t);
+    }
     await this.worker.close();
   }