use x-timeout value as request timeout

swisspost · Sep 26, 2024 · 98b36e0 · 98b36e0
1 parent a0c2495
commit 98b36e0
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/gateleen-queue/src/main/java/org/swisspush/gateleen/queue/queuing/QueueProcessor.java b/gateleen-queue/src/main/java/org/swisspush/gateleen/queue/queuing/QueueProcessor.java
@@ -292,7 +292,13 @@ private void executeQueuedRequest(Message<JsonObject> message, Logger logger, Ht
                     performCircuitBreakerActions(queueName, queuedRequest, FAILURE, state);
                 });
             };
-            request1.idleTimeout(120000); // avoids blocking other requests
+
+            if (queuedRequest.getHeaders().get("x-timeout") != null && !queuedRequest.getHeaders().get("x-timeout").isEmpty()) {
+                request1.idleTimeout((long) (Long.parseLong(queuedRequest.getHeaders().get("x-timeout")) * 1.1));
+            } else {
+                request1.idleTimeout(120000); // avoids blocking other requests
+            }
+
             if (queuedRequest.getPayload() != null) {
                 vertx.<Buffer>executeBlocking(() -> {
                     long beginEpchMs = currentTimeMillis();