diff --git a/packages/backend/src/boot/common.ts b/packages/backend/src/boot/common.ts index b6ab939644..3995545d7f 100644 --- a/packages/backend/src/boot/common.ts +++ b/packages/backend/src/boot/common.ts @@ -34,6 +34,7 @@ export async function jobQueue() { }); jobQueue.enableShutdownHooks(); + jobQueue.get(QueueProcessorService).start(); jobQueue.get(ChartManagementService).start(); return jobQueue; diff --git a/packages/backend/src/queue/QueueProcessorService.ts b/packages/backend/src/queue/QueueProcessorService.ts index 6ef760afb4..566d855308 100644 --- a/packages/backend/src/queue/QueueProcessorService.ts +++ b/packages/backend/src/queue/QueueProcessorService.ts @@ -77,7 +77,10 @@ export class QueueProcessorService implements OnApplicationShutdown { private cleanProcessorService: CleanProcessorService, ) { this.logger = this.queueLoggerService.logger; + } + @bindThis + public start(): void { function renderError(e: Error): any { if (e) { // 何故かeがundefinedで来ることがある return {