From dc380f5f247879657a776d4b910c8fe2b52fd6ba Mon Sep 17 00:00:00 2001
From: Bruno Thomas <bthomas@icij.org>
Date: Mon, 16 Sep 2024 12:54:43 +0000
Subject: [PATCH] fix: prefetch (basicQos) set to 0

---
 .../org/icij/datashare/asynctasks/bus/amqp/Configuration.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/Configuration.java b/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/Configuration.java
index a5202b97f..c45521513 100644
--- a/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/Configuration.java
+++ b/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/Configuration.java
@@ -13,6 +13,7 @@
  */
 public class Configuration {
 	private static final int DEFAULT_CONNECTION_RECOVERY_DELAY = 5000;
+	private static final int DEFAULT_PREFETCH_NUMBER = 1;
 	public final String host;
 	public final int port;
 	public final String user;
@@ -40,7 +41,7 @@ public Configuration(URI amqpAddress) {
 				stream(query.split("&")).
                         collect(Collectors.toMap(kv -> kv.split("=")[0], kv -> kv.split("=")[1]));
 		rabbitMq = Boolean.parseBoolean(ofNullable(properties.get("rabbitMq")).orElse("true"));
-		nbMaxMessages = Integer.parseInt(ofNullable(properties.get("nbMaxMessages")).orElse("100"));
+		nbMaxMessages = Integer.parseInt(ofNullable(properties.get("nbMaxMessages")).orElse(String.valueOf(DEFAULT_PREFETCH_NUMBER)));
 		requeueDelay = Integer.parseInt(ofNullable(properties.get("requeueDelay")).orElse("30"));
 		String connectionRecoveryDelayStr = properties.get("recoveryDelay");
 		connectionRecoveryDelay = connectionRecoveryDelayStr == null ?