Merge pull request #149 from swisspost/develop

PR for release with unit test fix
swisspost · Jan 15, 2024 · 11a3aef · 11a3aef
2 parents 2d3fe39 + 174788a
commit 11a3aef
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);