SDCISA-18049: Fix dead queues

Related: - SDCISA-18274
hiddenalpha · Nov 21, 2024 · 99f36d2 · 99f36d2
1 parent 866863b
commit 99f36d2
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) {