From 14f2b3ad1145595190ec515b3d8b23603d01281c Mon Sep 17 00:00:00 2001
From: Chocobozzz <me@florianbigard.com>
Date: Mon, 30 Jul 2018 18:49:54 +0200
Subject: Graceful job queue shutdown

---
 server/lib/job-queue/job-queue.ts | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'server')

diff --git a/server/lib/job-queue/job-queue.ts b/server/lib/job-queue/job-queue.ts
index b018d0e8a..157c57ba9 100644
--- a/server/lib/job-queue/job-queue.ts
+++ b/server/lib/job-queue/job-queue.ts
@@ -83,6 +83,13 @@ class JobQueue {
     }
   }
 
+  terminate () {
+    for (const queueName of Object.keys(this.queues)) {
+      const queue = this.queues[queueName]
+      queue.close()
+    }
+  }
+
   createJob (obj: CreateJobArgument) {
     const queue = this.queues[obj.type]
     if (queue === undefined) {
-- 
cgit v1.2.3