From b35b9bc27ff762938495d2ce73521fbe68643793 Mon Sep 17 00:00:00 2001
From: syuilo <Syuilotan@yahoo.co.jp>
Date: Mon, 29 May 2023 13:30:57 +0900
Subject: [PATCH] Update QueueProcessorService.ts
---
.../src/queue/QueueProcessorService.ts | 20 ++++++++++---------
1 file changed, 11 insertions(+), 9 deletions(-)
diff --git a/packages/backend/src/queue/QueueProcessorService.ts b/packages/backend/src/queue/QueueProcessorService.ts
index da5069c29e..42f9c1af7d 100644
--- a/packages/backend/src/queue/QueueProcessorService.ts
+++ b/packages/backend/src/queue/QueueProcessorService.ts
@@ -324,15 +324,17 @@ export class QueueProcessorService implements OnApplicationShutdown {
}
@bindThis
- public start() {
- this.systemQueueWorker.run();
- this.dbQueueWorker.run();
- this.deliverQueueWorker.run();
- this.inboxQueueWorker.run();
- this.webhookDeliverQueueWorker.run();
- this.relationshipQueueWorker.run();
- this.objectStorageQueueWorker.run();
- this.endedPollNotificationQueueWorker.run();
+ public async start(): Promise<void> {
+ await Promise.all([
+ this.systemQueueWorker.run(),
+ this.dbQueueWorker.run(),
+ this.deliverQueueWorker.run(),
+ this.inboxQueueWorker.run(),
+ this.webhookDeliverQueueWorker.run(),
+ this.relationshipQueueWorker.run(),
+ this.objectStorageQueueWorker.run(),
+ this.endedPollNotificationQueueWorker.run(),
+ ]);
}
@bindThis