diff --git a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java index 60c0bff85..e04d25777 100644 --- a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java +++ b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java @@ -470,8 +470,8 @@ public class MasterSlaveConnectionManager implements ConnectionManager { return null; } - Promise result = newPromise(); - Codec entryCodec = entry.getConnection().getChannels().get(channelName); + final Promise result = newPromise(); + final Codec entryCodec = entry.getConnection().getChannels().get(channelName); entry.unsubscribe(channelName, new BaseRedisPubSubListener() { @Override