add support for cluster auth

orkes-io · Aug 16, 2024 · 6db29b5 · 6db29b5
1 parent 76a829b
commit 6db29b5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...nductor-queues/src/main/java/io/orkes/conductor/queue/config/RedisQueueConfiguration.java b/...nductor-queues/src/main/java/io/orkes/conductor/queue/config/RedisQueueConfiguration.java
@@ -224,6 +224,7 @@ public JedisCluster createJedisCommands(QueueRedisProperties properties) {
                 Protocol.DEFAULT_TIMEOUT,
                 Protocol.DEFAULT_TIMEOUT,
                 DEFAULT_MAX_ATTEMPTS,
+                properties.getUsername(),
                 password,
                 null,
                 genericObjectPoolConfig,

diff --git a/orkes-conductor-queues/src/test/resources/logback.xml b/orkes-conductor-queues/src/test/resources/logback.xml
@@ -5,7 +5,7 @@
               class="ch.qos.logback.core.ConsoleAppender">
         <layout class="ch.qos.logback.classic.PatternLayout">
             <Pattern>
-                %black(%d{ISO8601}) %highlight(%-5level) [%blue(%t)] %yellow(%C{1.}): %msg%n%throwable
+                %black(%d{ISO8601}) %highlight(%-5level) [%blue(%t)] %yellow(%C): %msg%n%throwable
             </Pattern>
         </layout>
     </appender>