From c704f67e578a1758c9c02613813fff71adf6ea06 Mon Sep 17 00:00:00 2001 From: Alex Holliday Date: Fri, 29 May 2026 11:45:17 -0700 Subject: [PATCH] move listener registration to constructor --- server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts | 2 +- .../src/service/infrastructure/JobQueues/SuperSimpleQueue.ts | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts b/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts index 954f6ca91..1fa3d3e26 100644 --- a/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts +++ b/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts @@ -25,6 +25,7 @@ export class LessSimpleQueue implements IJobQueue { this.helper = helper; this.monitorsRepository = monitorsRepository; this.scheduler = scheduler; + this.registerListeners(); } get serviceName() { @@ -121,7 +122,6 @@ export class LessSimpleQueue implements IJobQueue { init = async () => { try { - this.registerListeners(); await this.scheduler.start(); this.scheduler.addTemplate("monitor-job", this.helper.getHeartbeatJob()); this.scheduler.addTemplate("geo-check-job", this.helper.getHeartbeatGeoJob()); diff --git a/server/src/service/infrastructure/JobQueues/SuperSimpleQueue.ts b/server/src/service/infrastructure/JobQueues/SuperSimpleQueue.ts index b98ecb2db..df265cf71 100644 --- a/server/src/service/infrastructure/JobQueues/SuperSimpleQueue.ts +++ b/server/src/service/infrastructure/JobQueues/SuperSimpleQueue.ts @@ -69,6 +69,7 @@ export class SuperSimpleQueue implements ISuperSimpleQueue { this.helper = helper; this.monitorsRepository = monitorsRepository; this.scheduler = scheduler; + this.registerListeners(); } get serviceName() { @@ -158,8 +159,6 @@ export class SuperSimpleQueue implements ISuperSimpleQueue { init = async () => { try { - this.registerListeners(); - this.scheduler.start(); this.scheduler.addTemplate("monitor-job", this.helper.getHeartbeatJob()); this.scheduler.addTemplate("geo-check-job", this.helper.getHeartbeatGeoJob());