This is an automated email from the ASF dual-hosted git repository.
hqtran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 08d30dd6ababe6831f69aea03c9cc3ccfec65914
Author: Quan Tran <hqt...@linagora.com>
AuthorDate: Mon Jun 2 13:38:27 2025 +0700
JAMES-3693 Redis sentinel client should take ioThreads and workerThreads
into account
---
.../java/org/apache/james/backends/redis/RedisClientFactory.scala | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/backends-common/redis/src/main/java/org/apache/james/backends/redis/RedisClientFactory.scala
b/backends-common/redis/src/main/java/org/apache/james/backends/redis/RedisClientFactory.scala
index 1b3b883d6a..8e9e4a213c 100644
---
a/backends-common/redis/src/main/java/org/apache/james/backends/redis/RedisClientFactory.scala
+++
b/backends-common/redis/src/main/java/org/apache/james/backends/redis/RedisClientFactory.scala
@@ -83,7 +83,11 @@ class RedisClientFactory @Singleton() @Inject()
}
private def createSentinelClient(sentinelRedisConfiguration:
SentinelRedisConfiguration): RedisClient = {
- val redisClient = RedisClient.create
+ val resourceBuilder: ClientResources.Builder = ClientResources.builder()
+ .threadFactoryProvider(threadFactoryProvider)
+ sentinelRedisConfiguration.ioThreads.foreach(value =>
resourceBuilder.ioThreadPoolSize(value))
+ sentinelRedisConfiguration.workerThreads.foreach(value =>
resourceBuilder.computationThreadPoolSize(value))
+ val redisClient = RedisClient.create(resourceBuilder.build(),
sentinelRedisConfiguration.redisURI)
redisClient.setOptions(createClientOptions(sentinelRedisConfiguration.useSSL,
sentinelRedisConfiguration.mayBeSSLConfiguration))
redisClient
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org
