public JedisCluster jedisCluster() { Set<HostAndPort> hostAndPorts = configModel.getNodes().stream().map(hp -> new HostAndPort(hp.getHost(), hp.getPort())).collect(toSet()); if (!StringUtils.isEmpty(configModel.getPassword())) { return new JedisCluster(hostAndPorts, configModel.getConnectionTimeout(), configModel.getSoTimeout(), configModel.getMaxAttempts(), configModel.getPassword(), configModel.getPoolConfig()); } JedisCluster jedisCluster = new JedisCluster(hostAndPorts, configModel.getPoolConfig()); log.info("jedisCluster {}", jedisCluster); return jedisCluster; }