|
|
@ -54,7 +54,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
|
|
|
|
init(config);
|
|
|
|
init(config);
|
|
|
|
|
|
|
|
|
|
|
|
for (URI addr : cfg.getNodeAddresses()) {
|
|
|
|
for (URI addr : cfg.getNodeAddresses()) {
|
|
|
|
RedisClient client = createClient(addr.getHost(), addr.getPort());
|
|
|
|
RedisClient client = createClient(addr.getHost(), addr.getPort(), cfg.getTimeout());
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
RedisAsyncConnection<String, String> connection = client.connectAsync();
|
|
|
|
RedisAsyncConnection<String, String> connection = client.connectAsync();
|
|
|
|
String nodesValue = get(connection.clusterNodes());
|
|
|
|
String nodesValue = get(connection.clusterNodes());
|
|
|
|