fix(job-queue-plugin): Close redis connection on destroy

vendure-ecommerce · Oct 7, 2021 · 64ebdd1 · 64ebdd1
1 parent f26ad4b
commit 64ebdd1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/packages/job-queue-plugin/src/bullmq/bullmq-job-queue-strategy.ts b/packages/job-queue-plugin/src/bullmq/bullmq-job-queue-strategy.ts
@@ -84,6 +84,10 @@ export class BullMQJobQueueStrategy implements InspectableJobQueueStrategy {
         }).on('error', (e: any) => Logger.error(`BullMQ Scheduler error: ${e.message}`, loggerCtx, e.stack));
     }
 
+    async destroy() {
+        await Promise.all([this.queue.close(), this.worker.close(), this.scheduler.close()]);
+    }
+
     async add<Data extends JobData<Data> = {}>(job: Job<Data>): Promise<Job<Data>> {
         const retries = this.options.setRetries?.(job.queueName, job) ?? job.retries;
         const backoff = this.options.setBackoff?.(job.queueName, job) ?? {