Expand message-related thread pools to 1 thread per shard.
This commit is contained in:
parent
572004d37a
commit
20c48b6bb2
|
@ -282,8 +282,8 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
|
||||||
ReplicatedJedisPool pushSchedulerClient = pushSchedulerClientFactory.getRedisClientPool();
|
ReplicatedJedisPool pushSchedulerClient = pushSchedulerClientFactory.getRedisClientPool();
|
||||||
|
|
||||||
ClientResources generalCacheClientResources = ClientResources.builder().build();
|
ClientResources generalCacheClientResources = ClientResources.builder().build();
|
||||||
ClientResources messageCacheClientResources = ClientResources.builder().ioThreadPoolSize(32).build();
|
ClientResources messageCacheClientResources = ClientResources.builder().ioThreadPoolSize(128).build();
|
||||||
ClientResources presenceClientResources = ClientResources.builder().ioThreadPoolSize(32).build();
|
ClientResources presenceClientResources = ClientResources.builder().ioThreadPoolSize(128).build();
|
||||||
ClientResources metricsCacheClientResources = ClientResources.builder().build();
|
ClientResources metricsCacheClientResources = ClientResources.builder().build();
|
||||||
|
|
||||||
ConnectionEventLogger.logConnectionEvents(generalCacheClientResources);
|
ConnectionEventLogger.logConnectionEvents(generalCacheClientResources);
|
||||||
|
|
Loading…
Reference in New Issue