From 99f36d22f4dd440dba39b3bc99af86e712bf38ea Mon Sep 17 00:00:00 2001
From: "Andreas Fankhauser hiddenalpha.ch"
 <23085769+hiddenalpha@users.noreply.github.com>
Date: Thu, 21 Nov 2024 11:28:46 +0100
Subject: [PATCH] SDCISA-18049: Fix dead queues

Related:
- SDCISA-18274
---
 src/main/java/org/swisspush/redisques/RedisQues.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java
index 1566336..fe375eb 100644
--- 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) {