Support changed CLUSTER SLOTS #183

redis · Jan 29, 2016 · b0dc59a · b0dc59a
1 parent 9414d4b
commit b0dc59a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/com/lambdaworks/redis/cluster/models/slots/ClusterSlotRange.java b/src/main/java/com/lambdaworks/redis/cluster/models/slots/ClusterSlotRange.java
@@ -96,8 +96,8 @@ private List<HostAndPort> toHostAndPorts(List<RedisClusterNode> nodes) {
 
     private RedisClusterNode toRedisClusterNode(HostAndPort hostAndPort, String slaveOf, Set<RedisClusterNode.NodeFlag> flags) {
         RedisClusterNode redisClusterNode = new RedisClusterNode();
-        redisClusterNode.setUri(RedisURI
-                .create(hostAndPort.getHostText(), hostAndPort.getPortOrDefault(RedisURI.DEFAULT_REDIS_PORT)));
+        redisClusterNode.setUri(new RedisURI
+                .Builder().redis(hostAndPort.getHostText(), hostAndPort.getPortOrDefault(RedisURI.DEFAULT_REDIS_PORT)).build());
         redisClusterNode.setSlaveOf(slaveOf);
         redisClusterNode.setFlags(flags);
         return redisClusterNode;

diff --git a/src/main/java/com/lambdaworks/redis/cluster/models/slots/ClusterSlotsParser.java b/src/main/java/com/lambdaworks/redis/cluster/models/slots/ClusterSlotsParser.java
@@ -101,7 +101,7 @@ private static RedisClusterNode getRedisClusterNode(Iterator<?> iterator) {
             String nodeId;
 
             RedisClusterNode redisClusterNode = new RedisClusterNode();
-            redisClusterNode.setUri(RedisURI.create(host, port));
+            redisClusterNode.setUri(new RedisURI.Builder().redis(host, port).build());
 
             if (hostAndPortIterator.hasNext()) {
                 nodeId = (String) hostAndPortIterator.next();