diff --git a/src/common/adapters/redis-io.adapter.ts b/src/common/adapters/redis-io.adapter.ts index c02b3c5..d0564a1 100644 --- a/src/common/adapters/redis-io.adapter.ts +++ b/src/common/adapters/redis-io.adapter.ts @@ -25,6 +25,9 @@ export class RedisIoAdapter extends IoAdapter { const pubClient = new Redis({ host, port, password, db }); const subClient = new Redis({ host, port, password, db }); + pubClient.on('error', (err) => this.logger.error(`Redis pub error: ${err.message}`)); + subClient.on('error', (err) => this.logger.error(`Redis sub error: ${err.message}`)); + await Promise.all([ new Promise((resolve) => pubClient.on('connect', resolve)), new Promise((resolve) => subClient.on('connect', resolve)),