mirror/Checkmate
1
0
Fork 0
mirror of https://github.com/bluewave-labs/Checkmate.git synced 2026-02-07 01:28:32 -06:00
Code Issues Packages Projects Releases Wiki Activity

add factory method, better logging

Browse Source
This commit is contained in:
Alex Holliday
2025-05-19 11:22:46 -07:00
parent e6a387b8b2
commit 3ff0f6d399
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
server/service/JobQueue/JobQueue.js
View File

@@ -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({