Added support for password protected redis server

jedis/deployment/src/main/java/org/pagan/quarkus/jedis/JedisProccessor.java

@@ -32,11 +32,17 @@ public class JedisProccessor {
 
     @Record(ExecutionTime.RUNTIME_INIT)
     @BuildStep
-    void build(JedisRecorder recorder, BuildProducer<ServiceStartBuildItem> serviceStart, BeanContainerBuildItem beanContainer, ShutdownContextBuildItem shutdownContext) {
+    void build(JedisRecorder recorder, BuildProducer<ServiceStartBuildItem> serviceStart,
+            BeanContainerBuildItem beanContainer, ShutdownContextBuildItem shutdownContext) {
         System.out.println("JedisProccessor - build");
-//            BuildProducer<ReflectiveClassBuildItem> reflectiveClassBuildItemBuildProducer) {
+        // BuildProducer<ReflectiveClassBuildItem>
-//        reflectiveClassBuildItemBuildProducer.produce(new ReflectiveClassBuildItem(false, false, BaseGenericObjectPool.class.getName()));
+        // reflectiveClassBuildItemBuildProducer) {
-//        reflectiveClassBuildItemBuildProducer.produce(new ReflectiveClassBuildItem(false, false, DefaultEvictionPolicy.class.getName()));
+        // reflectiveClassBuildItemBuildProducer.produce(new
+        // ReflectiveClassBuildItem(false, false,
+        // BaseGenericObjectPool.class.getName()));
+        // reflectiveClassBuildItemBuildProducer.produce(new
+        // ReflectiveClassBuildItem(false, false,
+        // DefaultEvictionPolicy.class.getName()));
         recorder.initialize(config, beanContainer.getValue(), shutdownContext);
         serviceStart.produce(new ServiceStartBuildItem("jedis"));
     }

jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisConfig.java

@@ -35,4 +35,10 @@ public class JedisConfig {
     @ConfigItem(defaultValue = "true")
     public boolean log;
 
+    /**
+     * Cluster access password
+     */
+    @ConfigItem(defaultValue = "")
+    public String password;
+
 }

jedis/runtime/src/main/java/org/pagan/quarkus/jedis/JedisSupport.java

@@ -10,6 +10,7 @@ import redis.clients.jedis.JedisPoolConfig;
 import redis.clients.jedis.JedisShardInfo;
 import redis.clients.jedis.ShardedJedisPool;
 import redis.clients.jedis.Jedis;
+import redis.clients.jedis.Protocol;
 import redis.clients.jedis.ShardedJedis;
 
 /**
@@ -35,12 +36,23 @@ public class JedisSupport {
         poolConfig.setJmxEnabled(true);
         if (config.shards.contains(",")) {
             List<JedisShardInfo> jedisShards = Arrays.stream(config.shards.split(",")).map(uri -> {
-                return new JedisShardInfo(URI.create(uri));
+                JedisShardInfo jedisShardInfo = new JedisShardInfo(URI.create(uri));
+                if (config.password.length() > 0) {
+                    jedisShardInfo.setPassword(config.password);
+                }
+                return jedisShardInfo;
             }).collect(Collectors.toList());
             this.shardedJedisPool = new ShardedJedisPool(poolConfig, jedisShards);
 
         } else {
-            this.jedisPool = new JedisPool(poolConfig, URI.create(config.shards));
+            URI server = URI.create(config.shards);
+            if (config.password.length() > 0) {
+                this.jedisPool = new JedisPool(poolConfig, server.getHost(), server.getPort(), Protocol.DEFAULT_TIMEOUT,
+                        config.password);
+            } else {
+                this.jedisPool = new JedisPool(poolConfig, server);
+            }
+
         }
     }