Mizah/mizzkey
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

fix(backend): restore start method in QueueProcessorService (#87)

Browse source
This commit is contained in:
まっちゃとーにゅ 2023-06-15 19:29:27 +09:00 committed by GitHub
parent e8cf53a1ea
commit e88617e3c3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
packages/backend/src/boot/common.ts
View file

@ -34,6 +34,7 @@ export async function jobQueue() {
}); });
jobQueue.enableShutdownHooks(); jobQueue.enableShutdownHooks();
jobQueue.get(QueueProcessorService).start();
jobQueue.get(ChartManagementService).start(); jobQueue.get(ChartManagementService).start();
return jobQueue; return jobQueue;

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

@ -77,7 +77,10 @@ export class QueueProcessorService implements OnApplicationShutdown {
private cleanProcessorService: CleanProcessorService, private cleanProcessorService: CleanProcessorService,
) { ) {
this.logger = this.queueLoggerService.logger; this.logger = this.queueLoggerService.logger;
}
@bindThis
public start(): void {
function renderError(e: Error): any { function renderError(e: Error): any {
if (e) { // 何故かeがundefinedで来ることがある if (e) { // 何故かeがundefinedで来ることがある
return { return {