From e79b22c6fe60865d834c097b0f494bb54f46f8da Mon Sep 17 00:00:00 2001 From: Nikita Date: Thu, 12 Oct 2017 11:21:18 +0300 Subject: [PATCH] DefaultChannelGroup initialization fixed --- redisson/src/main/java/org/redisson/client/RedisClient.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/client/RedisClient.java b/redisson/src/main/java/org/redisson/client/RedisClient.java index bc2f9bfd3..a6136ef52 100644 --- a/redisson/src/main/java/org/redisson/client/RedisClient.java +++ b/redisson/src/main/java/org/redisson/client/RedisClient.java @@ -79,9 +79,9 @@ public class RedisClient { addr = new InetSocketAddress(config.getAddress().getHost(), config.getAddress().getPort()); + channels = new DefaultChannelGroup(config.getGroup().next()); bootstrap = createBootstrap(config, Type.PLAIN); pubSubBootstrap = createBootstrap(config, Type.PUBSUB); - channels = new DefaultChannelGroup(config.getGroup().next()); this.commandTimeout = config.getCommandTimeout(); } @@ -172,9 +172,9 @@ public class RedisClient { addr = new InetSocketAddress(config.getAddress().getHost(), config.getAddress().getPort()); + channels = new DefaultChannelGroup(config.getGroup().next()); bootstrap = createBootstrap(config, Type.PLAIN); pubSubBootstrap = createBootstrap(config, Type.PUBSUB); - channels = new DefaultChannelGroup(config.getGroup().next()); this.commandTimeout = config.getCommandTimeout(); }