diff --git a/src/main/java/org/redisson/client/RedisConnection.java b/src/main/java/org/redisson/client/RedisConnection.java index 7ec96863b..c521ff7dd 100644 --- a/src/main/java/org/redisson/client/RedisConnection.java +++ b/src/main/java/org/redisson/client/RedisConnection.java @@ -42,13 +42,13 @@ public class RedisConnection implements RedisCommands { public RedisConnection(RedisClient redisClient, Channel channel) { super(); this.redisClient = redisClient; - this.channel = channel; - channel.attr(CONNECTION).set(this); + updateChannel(channel); } public void updateChannel(Channel channel) { this.channel = channel; + channel.attr(CONNECTION).set(this); } public RedisClient getRedisClient() {