fixed retry timestamp

swisspost · Jan 11, 2024 · bd196ef · bd196ef
1 parent 30a2424
commit bd196ef
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java
@@ -691,13 +691,17 @@ private void processMessageWithTimeout(final String queue, final String payload,
                 boolean success;
                 if (reply.succeeded()) {
                     success = OK.equals(reply.result().body().getString(STATUS));
-                    dequeueStatistic.get(queue).lastDequeueSuccessTimestamp = System.currentTimeMillis();
-                    dequeueStatistic.get(queue).nextDequeueDueTimestamp = null;
+                    if (success) {
+                        dequeueStatistic.get(queue).lastDequeueSuccessTimestamp = System.currentTimeMillis();
+                        dequeueStatistic.get(queue).nextDequeueDueTimestamp = null;
+                    }
                 } else {
                     log.info("RedisQues QUEUE_ERROR: Consumer failed {} queue: {}",
                             uid, queue, new Exception(reply.cause()));
                     success = Boolean.FALSE;
                 }
+
+
                 handler.handle(success);
             });
             updateTimestamp(queue, null);