refactoring

pull/2300/head
Nikita Koksharov 6 years ago
parent 80414518b7
commit f4a631482f

@ -106,7 +106,7 @@ public class RedisChannelInitializer extends ChannelInitializer<Channel> {
private void initSsl(final RedisClientConfig config, Channel ch) throws KeyStoreException, IOException, private void initSsl(final RedisClientConfig config, Channel ch) throws KeyStoreException, IOException,
NoSuchAlgorithmException, CertificateException, SSLException, UnrecoverableKeyException { NoSuchAlgorithmException, CertificateException, SSLException, UnrecoverableKeyException {
if (!"rediss".equals(config.getAddress().getScheme())) { if (!config.getAddress().isSsl()) {
return; return;
} }

@ -114,7 +114,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
} }
clusterNodesCommand = RedisCommands.CLUSTER_NODES; clusterNodesCommand = RedisCommands.CLUSTER_NODES;
if ("rediss".equals(addr.getScheme())) { if (addr.isSsl()) {
clusterNodesCommand = RedisCommands.CLUSTER_NODES_SSL; clusterNodesCommand = RedisCommands.CLUSTER_NODES_SSL;
} }

Loading…
Cancel
Save