Fixes a bug where performance would stall on ingestion workers under heavy load

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.");