This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 2f6a98add5 NIFI-15368 Replaced deprecated class JedisPoolConfig in the 
Jedis API, with its replacement ConnectionPoolConfig.
2f6a98add5 is described below

commit 2f6a98add5e67fc4543fbb22970e6edafafb80e0
Author: dan-s1 <[email protected]>
AuthorDate: Thu Dec 18 16:36:14 2025 +0000

    NIFI-15368 Replaced deprecated class JedisPoolConfig in the Jedis API, with 
its replacement ConnectionPoolConfig.
    
    Signed-off-by: Pierre Villard <[email protected]>
    
    This closes #10666.
---
 .../src/main/java/org/apache/nifi/redis/util/RedisUtils.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-utils/src/main/java/org/apache/nifi/redis/util/RedisUtils.java
 
b/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-utils/src/main/java/org/apache/nifi/redis/util/RedisUtils.java
index a66c9f2d7a..f647f94a3c 100644
--- 
a/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-utils/src/main/java/org/apache/nifi/redis/util/RedisUtils.java
+++ 
b/nifi-extension-bundles/nifi-redis-bundle/nifi-redis-utils/src/main/java/org/apache/nifi/redis/util/RedisUtils.java
@@ -44,7 +44,7 @@ import 
org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.data.redis.serializer.RedisSerializer;
 import org.springframework.data.redis.stream.StreamMessageListenerContainer;
 import org.springframework.lang.Nullable;
-import redis.clients.jedis.JedisPoolConfig;
+import redis.clients.jedis.ConnectionPoolConfig;
 
 import javax.net.ssl.SSLContext;
 
@@ -345,7 +345,7 @@ public class RedisUtils {
         final String sentinelUsername = redisConfig.getSentinelUsername();
         final String sentinelPassword = redisConfig.getSentinelPassword();
         final Integer timeout = redisConfig.getTimeout();
-        final JedisPoolConfig poolConfig = createJedisPoolConfig(redisConfig);
+        final ConnectionPoolConfig poolConfig = 
createConnectionPoolConfig(redisConfig);
 
         JedisClientConfiguration.JedisClientConfigurationBuilder builder = 
JedisClientConfiguration.builder()
                 .connectTimeout(Duration.ofMillis(timeout))
@@ -442,8 +442,8 @@ public class RedisUtils {
         }
     }
 
-    private static JedisPoolConfig createJedisPoolConfig(final RedisConfig 
redisConfig) {
-        final JedisPoolConfig poolConfig = new JedisPoolConfig();
+    private static ConnectionPoolConfig createConnectionPoolConfig(final 
RedisConfig redisConfig) {
+        final ConnectionPoolConfig poolConfig = new ConnectionPoolConfig();
         poolConfig.setMaxTotal(redisConfig.getPoolMaxTotal());
         poolConfig.setMaxIdle(redisConfig.getPoolMaxIdle());
         poolConfig.setMinIdle(redisConfig.getPoolMinIdle());

Reply via email to