refactoring

redisson · May 10, 2024 · 7a8ee73 · 7a8ee73
1 parent ab31631
commit 7a8ee73
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/redisson/src/main/java/org/redisson/RedissonReliableTopic.java b/redisson/src/main/java/org/redisson/RedissonReliableTopic.java
@@ -193,6 +193,10 @@ private void poll(String id) {
                 log.error(ex.getCause().getMessage(), ex.getCause());
 
                 getServiceManager().newTimeout(task -> {
+                    if (getServiceManager().isShuttingDown()) {
+                        return;
+                    }
+
                     poll(id);
                 }, 1, TimeUnit.SECONDS);
                 return;
@@ -325,7 +329,7 @@ public RFuture<Integer> countSubscribersAsync() {
 
     private void renewExpiration() {
         timeoutTask = getServiceManager().newTimeout(t -> {
-            if (!subscribed.get()) {
+            if (!subscribed.get() || getServiceManager().isShuttingDown()) {
                 return;
             }