diff --git a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java index edeb637a9..4e24cec49 100644 --- a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java +++ b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java @@ -450,6 +450,7 @@ public class MasterSlaveConnectionManager implements ConnectionManager { public PubSubConnectionEntry subscribeOnce(RedisPubSubAdapter listener, String channelName) { PubSubConnectionEntry сonnEntry = name2PubSubConnection.get(channelName); if (сonnEntry != null) { + сonnEntry.subscribe(listener, channelName); return сonnEntry; }