diff --git a/API.paw b/API.paw index 1a6987ce4a100f1b51b1ca50c332af3fc3fb11e1..ba6dcaff425692893fe3aba73cbd1315f7998830 100644 Binary files a/API.paw and b/API.paw differ diff --git a/src/services/IngestionService.ts b/src/services/IngestionService.ts index b819da0c3f3699bf6dcdfbccff0b4350070829c2..f795aa60cb66ed46e31c7acc59615c8eafb86314 100644 --- a/src/services/IngestionService.ts +++ b/src/services/IngestionService.ts @@ -64,8 +64,10 @@ class IngestionService { start(): void { logger.info("Starting IngestionService"); - // Only one message should be processed at a time. - this.channel.prefetch(1); + // Process up to three messages at a time. + // While one message waits for the database, + // the other two can be processed. + this.channel.prefetch(3); this.channel.consume(config.rabbitMQ.queue, (message) => { if(!message) {