do not always requeue when you should only requeue deleted messages

agorapulse · Mar 3, 2025 · 0dfd4c0 · 0dfd4c0
1 parent 5a9c765
commit 0dfd4c0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/queue/DefaultQueueMessage.java b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/queue/DefaultQueueMessage.java
@@ -24,7 +24,7 @@ static <T> DefaultQueueMessage<T> alwaysRequeue(String id, T message, Runnable d
     }
 
     static <T> DefaultQueueMessage<T> requeueIfDeleted(String id, T message, Runnable doDelete, Runnable doRequeue) {
-        return new DefaultQueueMessage<>(id, message, doDelete, doRequeue, true);
+        return new DefaultQueueMessage<>(id, message, doDelete, doRequeue, false);
     }
 
     private final String id;