feat: change monitoring queue expiration to 1 hour #1638

ICIJ · Jan 23, 2025 · 6d816bc · 6d816bc
1 parent 146e528
commit 6d816bc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/AmqpQueue.java b/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/AmqpQueue.java
@@ -22,7 +22,7 @@ public enum AmqpQueue {
 	WORKER_EVENT("exchangeWorkerEvents", BuiltinExchangeType.FANOUT, "routingKeyWorkerEvents"),
 	MONITORING("exchangeMonitoring", BuiltinExchangeType.DIRECT, "routingKeyMonitoring", Map.of(
 			"x-message-ttl", 5000,
-			"x-expires", 10000), null);
+			"x-expires", 3600 * 1000), null);
 
 	public final String exchange;
 	public final String routingKey;