@@ -425,9 +425,9 @@ protected JedisCluster createCluster(RedisClusterConfiguration clusterConfig, Ge
425
425
int redirects = clusterConfig .getMaxRedirects () != null ? clusterConfig .getMaxRedirects () : 5 ;
426
426
427
427
return new JedisCluster (hostAndPort , getConnectTimeout (), getReadTimeout (), redirects , getPassword (),
428
- clientConfiguration . getClientName (). orElse ( null ) , poolConfig , isUseSsl (),
429
- clientConfiguration .getSslSocketFactory ().orElse (null ), clientConfiguration .getSslParameters ().orElse (null ),
430
- clientConfiguration . getHostnameVerifier (). orElse ( null ), null );
428
+ getClientName (), poolConfig , isUseSsl (), clientConfiguration . getSslSocketFactory (). orElse ( null ),
429
+ clientConfiguration .getSslParameters ().orElse (null ), clientConfiguration .getHostnameVerifier ().orElse (null ),
430
+ null );
431
431
}
432
432
433
433
/*
@@ -473,9 +473,8 @@ public RedisConnection getConnection() {
473
473
}
474
474
475
475
Jedis jedis = fetchJedisConnector ();
476
- String clientName = clientConfiguration .getClientName ().orElse (null );
477
- JedisConnection connection = (getUsePool () ? new JedisConnection (jedis , pool , getDatabase (), clientName )
478
- : new JedisConnection (jedis , null , getDatabase (), clientName ));
476
+ JedisConnection connection = (getUsePool () ? new JedisConnection (jedis , pool , getDatabase (), getClientName ())
477
+ : new JedisConnection (jedis , null , getDatabase (), getClientName ()));
479
478
connection .setConvertPipelineAndTxResults (convertPipelineAndTxResults );
480
479
return postProcessConnection (connection );
481
480
}
@@ -549,6 +548,7 @@ public void setUseSsl(boolean useSsl) {
549
548
*
550
549
* @return password for authentication.
551
550
*/
551
+ @ Nullable
552
552
public String getPassword () {
553
553
return getRedisPassword ().map (String ::new ).orElse (null );
554
554
}
0 commit comments