From 3ff0f6d39990f4d2eae2e5723b4f81aba1ca4c1e Mon Sep 17 00:00:00 2001
From: Alex Holliday <ajhollid@gmail.com>
Date: Mon, 19 May 2025 11:22:46 -0700
Subject: [PATCH] add factory method, better logging

---
 server/service/JobQueue/JobQueue.js | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

diff --git a/server/service/JobQueue/JobQueue.js b/server/service/JobQueue/JobQueue.js
index 84d603df5..32d531809 100644
--- a/server/service/JobQueue/JobQueue.js
+++ b/server/service/JobQueue/JobQueue.js
@@ -22,7 +22,12 @@ class JobQueue {
 		this.logger = logger;
 		this.queues = {};
 		this.workers = [];
-		this.init();
+	}
+
+	static async create({ db, jobQueueHelper, logger, stringService }) {
+		const instance = new JobQueue({ db, jobQueueHelper, logger, stringService });
+		await instance.init();
+		return instance;
 	}
 
 	async init() {
@@ -52,9 +57,13 @@ class JobQueue {
 					const queueHealthChecks = await this.checkQueueHealth();
 					const queueIsStuck = queueHealthChecks.some((healthCheck) => healthCheck.stuck);
 					if (queueIsStuck) {
-						console.log("Queue is stuck");
-						console.log(queueHealthChecks);
-						// await this.flushQueues();
+						this.logger.warn({
+							message: "Queue is stuck",
+							service: SERVICE_NAME,
+							method: "periodicHealthCheck",
+							details: queueHealthChecks,
+						});
+						await this.flushQueues();
 					}
 				} catch (error) {
 					this.logger.error({