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 0ded0a27dfc0a2bd822de409b6dbf6ec9c4f1b08
Author: Quan Tran <hqt...@linagora.com>
AuthorDate: Mon Jun 2 12:02:37 2025 +0700
JAMES-3693 Redis master/replica 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 a946df18b9..1b3b883d6a 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
@@ -73,7 +73,11 @@ class RedisClientFactory @Singleton() @Inject()
}
private def createMasterReplicaClient(masterReplicaRedisConfiguration:
MasterReplicaRedisConfiguration): RedisClient = {
- val redisClient = RedisClient.create
+ val resourceBuilder: ClientResources.Builder = ClientResources.builder()
+ .threadFactoryProvider(threadFactoryProvider)
+ masterReplicaRedisConfiguration.ioThreads.foreach(value =>
resourceBuilder.ioThreadPoolSize(value))
+ masterReplicaRedisConfiguration.workerThreads.foreach(value =>
resourceBuilder.computationThreadPoolSize(value))
+ val redisClient = RedisClient.create(resourceBuilder.build())
redisClient.setOptions(createClientOptions(masterReplicaRedisConfiguration.useSSL,
masterReplicaRedisConfiguration.mayBeSSLConfiguration))
redisClient
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org
