mirror of
https://github.com/bluewave-labs/Checkmate.git
synced 2026-05-08 01:30:01 -05:00
add factory method
This commit is contained in:
+6
-1
@@ -210,7 +210,12 @@ const startApp = async () => {
|
|||||||
statusService,
|
statusService,
|
||||||
notificationService,
|
notificationService,
|
||||||
});
|
});
|
||||||
const pulseQueue = new PulseQueue({ appSettings, db, pulseQueueHelper, logger });
|
const pulseQueue = await PulseQueue.create({
|
||||||
|
appSettings,
|
||||||
|
db,
|
||||||
|
pulseQueueHelper,
|
||||||
|
logger,
|
||||||
|
});
|
||||||
|
|
||||||
// Register services
|
// Register services
|
||||||
// ServiceRegistry.register(JobQueue.SERVICE_NAME, jobQueue);
|
// ServiceRegistry.register(JobQueue.SERVICE_NAME, jobQueue);
|
||||||
|
|||||||
@@ -10,7 +10,12 @@ class PulseQueue {
|
|||||||
this.appSettings = appSettings;
|
this.appSettings = appSettings;
|
||||||
this.pulseQueueHelper = pulseQueueHelper;
|
this.pulseQueueHelper = pulseQueueHelper;
|
||||||
this.logger = logger;
|
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;
|
||||||
}
|
}
|
||||||
|
|
||||||
// ****************************************
|
// ****************************************
|
||||||
|
|||||||
Reference in New Issue
Block a user