Bugfix: Use authentication in cluster topology refresh #171

redis · Dec 25, 2015 · 5e2c9f6 · 5e2c9f6
1 parent 0a2a6f3
commit 5e2c9f6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/lambdaworks/redis/cluster/ClusterTopologyRefresh.java b/src/main/java/com/lambdaworks/redis/cluster/ClusterTopologyRefresh.java
@@ -232,6 +232,9 @@ private Map<RedisURI, StatefulRedisConnection<String, String>> getConnections(It
 
             try {
                 StatefulRedisConnection<String, String> connection = client.connectToNode(redisURI.getResolvedAddress());
+                if(redisURI.getPassword() != null && redisURI.getPassword().length != 0) {
+                    connection.sync().auth(new String(redisURI.getPassword()));
+                }
                 connections.put(redisURI, connection);
             } catch (RedisConnectionException e) {
                 if (logger.isDebugEnabled()) {