#615 Added x-originally-queued header to queued requests to disting…

…uish them from `enqueuing` requests
swisspost · Dec 9, 2024 · 06e4ed9 · 06e4ed9
1 parent ba5f999
commit 06e4ed9
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/gateleen-queue/src/main/java/org/swisspush/gateleen/queue/queuing/QueuingHandler.java b/gateleen-queue/src/main/java/org/swisspush/gateleen/queue/queuing/QueuingHandler.java
@@ -26,6 +26,7 @@
 public class QueuingHandler implements Handler<Buffer> {
 
     public static final String QUEUE_HEADER = "x-queue";
+    public static final String ORIGINALLY_QUEUED_HEADER = "x-originally-queued";
     public static final String DUPLICATE_CHECK_HEADER = "x-duplicate-check";
 
     private final RequestQueue requestQueue;
@@ -86,6 +87,9 @@ public void handle(final Buffer buffer) {
         // Remove the queue header to avoid feedback loop
         headers.remove(QUEUE_HEADER);
 
+        // Add a header to indicate that this request was initially queued
+        headers.add(ORIGINALLY_QUEUED_HEADER, "true");
+
         if (headers.names().contains(DUPLICATE_CHECK_HEADER)) {
             DuplicateCheckHandler.checkDuplicateRequest(redisProvider, request.uri(), buffer, headers.get(DUPLICATE_CHECK_HEADER), requestIsDuplicate -> {
                 if (requestIsDuplicate) {