diff --git a/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisConfig.java b/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisConfig.java index 6bdfceb..3a468d9 100644 --- a/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisConfig.java +++ b/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisConfig.java @@ -3,6 +3,7 @@ package org.pagan.quarkus.jedis; import io.quarkus.runtime.annotations.ConfigItem; import io.quarkus.runtime.annotations.ConfigPhase; import io.quarkus.runtime.annotations.ConfigRoot; +import java.util.Optional; /** * @@ -39,6 +40,6 @@ public class JedisConfig { * Cluster access password */ @ConfigItem(defaultValue = "") - public String password; + public Optional password; } diff --git a/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisSupport.java b/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisSupport.java index 71b5899..ec25bc9 100644 --- a/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisSupport.java +++ b/jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisSupport.java @@ -37,8 +37,8 @@ public class JedisSupport { if (config.shards.contains(",")) { List jedisShards = Arrays.stream(config.shards.split(",")).map(uri -> { JedisShardInfo jedisShardInfo = new JedisShardInfo(URI.create(uri)); - if (config.password.length() > 0) { - jedisShardInfo.setPassword(config.password); + if (config.password.isPresent()) { + jedisShardInfo.setPassword(config.password.get()); } return jedisShardInfo; }).collect(Collectors.toList()); @@ -46,9 +46,9 @@ public class JedisSupport { } else { URI server = URI.create(config.shards); - if (config.password.length() > 0) { + if (config.password.isPresent()) { this.jedisPool = new JedisPool(poolConfig, server.getHost(), server.getPort(), Protocol.DEFAULT_TIMEOUT, - config.password); + config.password.get()); } else { this.jedisPool = new JedisPool(poolConfig, server); }