diff --git a/src/services/IngestionService.ts b/src/services/IngestionService.ts index 736b2bfb125eee8663ed6e5db468c70bc5e7e4eb..5ff32d6c74070b483137fb1974ea4381db4c97ab 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.");