Merge pull request #95 from Monits/master

Make sure the pubsub listener is subscribed
pull/99/head
Nikita Koksharov 10 years ago
commit 2ea7ff44e1

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

Loading…
Cancel
Save