Merge pull request #222 from hiddenalpha/FixDeadQueues-20241121

SDCISA-18049: Fix dead queues
swisspost · Nov 21, 2024 · 430f94d · 430f94d
2 parents 866863b + 99f36d2
commit 430f94d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java
@@ -578,6 +578,7 @@ private void registerActiveQueueRegistrationRefresh() {
                     }
                     @Override public boolean onError(Throwable ex, Iterator<Map.Entry<String, QueueState>> iter) {
                         if (log.isWarnEnabled()) log.warn("TODO error handling", exceptionFactory.newException(ex));
+                        onPeriodicDone.run();
                         return false;
                     }
                     @Override public void onDone(Iterator<Map.Entry<String, QueueState>> iter) {