chore: close connections when bull-queue is about to close

acidiney · Feb 6, 2024 · a70fed3 · a70fed3
1 parent 735bc2c
commit a70fed3
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/providers/queue_provider.ts b/providers/queue_provider.ts
@@ -36,4 +36,12 @@ export default class QueueProvider {
       return new BullManager(config, logger, app)
     })
   }
+
+  async shutdown() {
+    const bullQueue = await this.app.container.make('bull_queue')
+
+    bullQueue.list().forEach(async (queue) => {
+      await queue.close()
+    })
+  }
 }