diff --git a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java index ecb7ab02a..c0e424be7 100644 --- a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java +++ b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java @@ -451,6 +451,9 @@ public class MasterSlaveConnectionManager implements ConnectionManager { PubSubConnectionEntry сonnEntry = name2PubSubConnection.get(channelName); if (сonnEntry != null) { сonnEntry.addListener(channelName, listener); + // notify subscribed manually + listener.subscribed(channelName, 1); + listener.psubscribed(channelName, 1); return сonnEntry; }