diff --git a/src/config.ts b/src/config.ts index 296f7ce..568aa0c 100644 --- a/src/config.ts +++ b/src/config.ts @@ -137,7 +137,8 @@ addDefaults(config, { disableOfflineQueue: true, expiryTime: 24 * 60 * 60, getTimeout: 40, - maxConnections: 15000 + maxConnections: 15000, + maxWriteConnections: 1000 }, redisRead: { enabled: false, diff --git a/src/types/config.model.ts b/src/types/config.model.ts index 9888209..3450b72 100644 --- a/src/types/config.model.ts +++ b/src/types/config.model.ts @@ -6,6 +6,7 @@ interface RedisConfig extends redis.RedisClientOptions { expiryTime: number; getTimeout: number; maxConnections: number; + maxWriteConnections: number; } interface RedisReadOnlyConfig extends redis.RedisClientOptions { diff --git a/src/utils/redis.ts b/src/utils/redis.ts index 900d0fb..4106606 100644 --- a/src/utils/redis.ts +++ b/src/utils/redis.ts @@ -68,7 +68,7 @@ if (config.redis?.enabled) { }); }); exportClient.set = (key, value) => new Promise((resolve, reject) => { - if (activeRequests > config.redis.maxConnections) { + if (activeRequests > config.redis.maxWriteConnections) { reject("Too many active requests"); return; }