diff options
| author | tamaina <tamaina@hotmail.co.jp> | 2023-01-22 12:07:38 +0000 |
|---|---|---|
| committer | tamaina <tamaina@hotmail.co.jp> | 2023-01-22 12:07:38 +0000 |
| commit | a8b19f4aa8ca014ee4f86f15279c1b9b0b592c65 (patch) | |
| tree | 779967d21452e8fab4d9ec872a1277ac68f95956 /packages/backend/src/boot/worker.ts | |
| parent | refactor (diff) | |
| parent | 13.1.7 (diff) | |
| download | misskey-a8b19f4aa8ca014ee4f86f15279c1b9b0b592c65.tar.gz misskey-a8b19f4aa8ca014ee4f86f15279c1b9b0b592c65.tar.bz2 misskey-a8b19f4aa8ca014ee4f86f15279c1b9b0b592c65.zip | |
Merge branch 'develop' into emoji-re
Diffstat (limited to 'packages/backend/src/boot/worker.ts')
| -rw-r--r-- | packages/backend/src/boot/worker.ts | 19 |
1 files changed, 5 insertions, 14 deletions
diff --git a/packages/backend/src/boot/worker.ts b/packages/backend/src/boot/worker.ts index f29e37de78..e0574643b7 100644 --- a/packages/backend/src/boot/worker.ts +++ b/packages/backend/src/boot/worker.ts @@ -1,32 +1,23 @@ import cluster from 'node:cluster'; import { NestFactory } from '@nestjs/core'; -import { envOption } from '@/env.js'; import { ChartManagementService } from '@/core/chart/ChartManagementService.js'; -import { ServerService } from '@/server/ServerService.js'; import { QueueProcessorService } from '@/queue/QueueProcessorService.js'; import { NestLogger } from '@/NestLogger.js'; -import { RootModule } from '../RootModule.js'; +import { QueueProcessorModule } from '@/queue/QueueProcessorModule.js'; /** * Init worker process */ export async function workerMain() { - const app = await NestFactory.createApplicationContext(RootModule, { + const jobQueue = await NestFactory.createApplicationContext(QueueProcessorModule, { logger: new NestLogger(), }); - app.enableShutdownHooks(); - - // start server - const serverService = app.get(ServerService); - serverService.launch(); + jobQueue.enableShutdownHooks(); // start job queue - if (!envOption.onlyServer) { - const queueProcessorService = app.get(QueueProcessorService); - queueProcessorService.start(); - } + jobQueue.get(QueueProcessorService).start(); - app.get(ChartManagementService).run(); + jobQueue.get(ChartManagementService).start(); if (cluster.isWorker) { // Send a 'ready' message to parent process |