Merge pull request #218 from hiddenalpha/FixLyingTimeLogger-20241029

Fix misleading log
swisspost · Oct 30, 2024 · c94186c · c94186c
2 parents 9fd76db + 3bcad4a
commit c94186c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java
@@ -1248,7 +1248,6 @@ private Future<Void> checkQueues() {
                             }
                         });
                     } else {
-                        log.debug("all queue items time used is {} ms", System.currentTimeMillis() - startTs);
                         onDone.accept(null, null);
                     }
                     return ctx.iter.hasNext();
@@ -1263,6 +1262,7 @@ private Future<Void> checkQueues() {
                     ctx.counter = null;
                     ctx.iter = null;
                     // Mark this composition step as completed.
+                    log.debug("all queue items time used is {} ms", System.currentTimeMillis() - startTs);
                     p.complete();
                 }
             });