From 20c48b6bb2aed3701ebfa0fabee8279e0c05f1d4 Mon Sep 17 00:00:00 2001
From: Jon Chambers <jon@signal.org>
Date: Sat, 16 Jan 2021 01:44:01 -0500
Subject: [PATCH] Expand message-related thread pools to 1 thread per shard.

---
 .../whispersystems/textsecuregcm/WhisperServerService.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
index 4a0dab310..a755997a5 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
@@ -282,8 +282,8 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
     ReplicatedJedisPool pushSchedulerClient = pushSchedulerClientFactory.getRedisClientPool();
 
     ClientResources generalCacheClientResources = ClientResources.builder().build();
-    ClientResources messageCacheClientResources = ClientResources.builder().ioThreadPoolSize(32).build();
-    ClientResources presenceClientResources     = ClientResources.builder().ioThreadPoolSize(32).build();
+    ClientResources messageCacheClientResources = ClientResources.builder().ioThreadPoolSize(128).build();
+    ClientResources presenceClientResources     = ClientResources.builder().ioThreadPoolSize(128).build();
     ClientResources metricsCacheClientResources = ClientResources.builder().build();
 
     ConnectionEventLogger.logConnectionEvents(generalCacheClientResources);