diff --git a/providers/queue_provider.ts b/providers/queue_provider.ts index 0f72084..1da998e 100644 --- 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() + }) + } }