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());