diff --git a/server/index.js b/server/index.js
index 81970ae7a..dccf77c9b 100755
--- a/server/index.js
+++ b/server/index.js
@@ -210,7 +210,12 @@ const startApp = async () => {
 		statusService,
 		notificationService,
 	});
-	const pulseQueue = new PulseQueue({ appSettings, db, pulseQueueHelper, logger });
+	const pulseQueue = await PulseQueue.create({
+		appSettings,
+		db,
+		pulseQueueHelper,
+		logger,
+	});
 
 	// Register services
 	// ServiceRegistry.register(JobQueue.SERVICE_NAME, jobQueue);
diff --git a/server/service/PulseQueue/PulseQueue.js b/server/service/PulseQueue/PulseQueue.js
index 25dcbd4d9..fd420400f 100644
--- a/server/service/PulseQueue/PulseQueue.js
+++ b/server/service/PulseQueue/PulseQueue.js
@@ -10,7 +10,12 @@ class PulseQueue {
 		this.appSettings = appSettings;
 		this.pulseQueueHelper = pulseQueueHelper;
 		this.logger = logger;
-		this.init();
+	}
+
+	static async create({ appSettings, db, pulseQueueHelper, logger }) {
+		const instance = new PulseQueue({ appSettings, db, pulseQueueHelper, logger });
+		await instance.init();
+		return instance;
 	}
 
 	// ****************************************