SDCISA-18049: Fix dead queues

hiddenalpha · hiddenalpha · commit 99f36d22f4dd · 2024-11-21T11:28:46.000+01:00
Related:
- SDCISA-18274
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) {

Original file line number	Diff line number	Diff line change
`@@ -578,6 +578,7 @@ private void registerActiveQueueRegistrationRefresh() {`
`578`	`578`	`}`
`579`	`579`	`@Override public boolean onError(Throwable ex, Iterator<Map.Entry<String, QueueState>> iter) {`
`580`	`580`	`if (log.isWarnEnabled()) log.warn("TODO error handling", exceptionFactory.newException(ex));`
	`581`	`+ onPeriodicDone.run();`
`581`	`582`	`return false;`
`582`	`583`	`}`
`583`	`584`	`@Override public void onDone(Iterator<Map.Entry<String, QueueState>> iter) {`