keith/barkey
1
0
Fork 0
mirror of https://codeberg.org/yeentown/barkey synced 2024-11-25 08:15:12 +00:00
Code Issues Projects Releases Packages Wiki Activity

Update QueueProcessorService.ts

Browse source
This commit is contained in:
syuilo 2023-05-29 13:30:57 +09:00
parent 4790ddfad6
commit b35b9bc27f
1 changed files with 11 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
packages/backend/src/queue/QueueProcessorService.ts
View file

@ -324,15 +324,17 @@ export class QueueProcessorService implements OnApplicationShutdown {
} }
@bindThis @bindThis
public start() { public async start(): Promise<void> {
this.systemQueueWorker.run(); await Promise.all([
this.dbQueueWorker.run(); this.systemQueueWorker.run(),
this.deliverQueueWorker.run(); this.dbQueueWorker.run(),
this.inboxQueueWorker.run(); this.deliverQueueWorker.run(),
this.webhookDeliverQueueWorker.run(); this.inboxQueueWorker.run(),
this.relationshipQueueWorker.run(); this.webhookDeliverQueueWorker.run(),
this.objectStorageQueueWorker.run(); this.relationshipQueueWorker.run(),
this.endedPollNotificationQueueWorker.run(); this.objectStorageQueueWorker.run(),
this.endedPollNotificationQueueWorker.run(),
]);
} }
@bindThis @bindThis