|
|
@ -470,8 +470,8 @@ public class MasterSlaveConnectionManager implements ConnectionManager {
|
|
|
|
return null;
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
Promise<Codec> result = newPromise();
|
|
|
|
final Promise<Codec> result = newPromise();
|
|
|
|
Codec entryCodec = entry.getConnection().getChannels().get(channelName);
|
|
|
|
final Codec entryCodec = entry.getConnection().getChannels().get(channelName);
|
|
|
|
entry.unsubscribe(channelName, new BaseRedisPubSubListener() {
|
|
|
|
entry.unsubscribe(channelName, new BaseRedisPubSubListener() {
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|