Make sure the pubsub listener is subscribed

- When a connection is reused, the listener should still be subscribed.
pull/95/head
Juan Martín Sotuyo Dodero 10 years ago
parent 12b6fd057b
commit 3331713b54

@ -450,6 +450,7 @@ public class MasterSlaveConnectionManager implements ConnectionManager {
public <K, V> PubSubConnectionEntry subscribeOnce(RedisPubSubAdapter<V> listener, String channelName) {
PubSubConnectionEntry сonnEntry = name2PubSubConnection.get(channelName);
if (сonnEntry != null) {
сonnEntry.subscribe(listener, channelName);
return сonnEntry;
}

Loading…
Cancel
Save