diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java index afc3434..7cc1021 100644 --- a/src/main/java/org/swisspush/redisques/RedisQues.java +++ b/src/main/java/org/swisspush/redisques/RedisQues.java @@ -1248,7 +1248,6 @@ private Future 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 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(); } });