Merge pull request #3689 from bluewave-labs/fix/listener-leak

fix: move listener registration to constructor

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());

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());