From e88617e3c3418316152e2f8a62b951d71991deca Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E3=81=BE=E3=81=A3=E3=81=A1=E3=82=83=E3=81=A8=E3=83=BC?= =?UTF-8?q?=E3=81=AB=E3=82=85?= <17376330+u1-liquid@users.noreply.github.com> Date: Thu, 15 Jun 2023 19:29:27 +0900 Subject: [PATCH] fix(backend): restore start method in QueueProcessorService (#87) --- packages/backend/src/boot/common.ts | 1 + packages/backend/src/queue/QueueProcessorService.ts | 3 +++ 2 files changed, 4 insertions(+) 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 {