From b04cb21be8b7975220060e2c6877712b1e36d489 Mon Sep 17 00:00:00 2001 From: Jonas Schlabertz <jonas@schlabertz.de> Date: Sun, 5 Jun 2022 22:45:59 +0200 Subject: [PATCH] Fixes a bug where performance would stall on ingestion workers under heavy load --- src/services/IngestionService.ts | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/services/IngestionService.ts b/src/services/IngestionService.ts index 736b2bf..5ff32d6 100644 --- a/src/services/IngestionService.ts +++ b/src/services/IngestionService.ts @@ -64,6 +64,9 @@ class IngestionService { start(): void { logger.info("Starting IngestionService"); + // Only one message should be processed at a time. + this.channel.prefetch(1); + this.channel.consume(config.rabbitMQ.queue, (message) => { if(!message) { logger.error("Received empty message."); -- GitLab