Boosts performance.

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) {