From 35b85c1cc0ab240b91c576e2e2f1619c904aab54 Mon Sep 17 00:00:00 2001 From: pradeepkumar Date: Tue, 7 Apr 2026 13:17:18 +0530 Subject: [PATCH] fix: configure redis client options and optimize subscriber initialization using duplicate connection --- src/common/adapters/redis-io.adapter.ts | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/src/common/adapters/redis-io.adapter.ts b/src/common/adapters/redis-io.adapter.ts index 1ffb8d5..747ba1f 100644 --- a/src/common/adapters/redis-io.adapter.ts +++ b/src/common/adapters/redis-io.adapter.ts @@ -23,13 +23,20 @@ export class RedisIoAdapter extends IoAdapter { const db = this.configService.get('redis.db', 0); const useTls = process.env.REDIS_TLS === 'true'; - const opts: any = { host, port, password, db }; + const opts: any = { + host, + port, + password, + db, + maxRetriesPerRequest: null, + enableReadyCheck: false, + }; if (useTls) { opts.tls = { rejectUnauthorized: false }; } const pubClient = new Redis(opts); - const subClient = new Redis(opts); + const subClient = pubClient.duplicate(); pubClient.on('error', (err) => this.logger.error(`Redis pub error: ${err.message}`)); subClient.on('error', (err) => this.logger.error(`Redis sub error: ${err.message}`));