refactoring

4 years ago · 42313bab53
parent e4cd993c8a
commit 42313bab53
1 changed files with 1 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java
+++ b/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java
@ -696,7 +696,7 @@ public class PublishSubscribeService {
                        semaphore.release();
                        promise.trySuccess(null);
                    }
-                    return;
+                    continue;
                }

                for (int id : listenerIds) {