From ac00a005220aa48e9be509f18594bd5e13969ce4 Mon Sep 17 00:00:00 2001 From: Marc Bachmann Date: Thu, 31 Mar 2022 15:06:40 +0200 Subject: [PATCH] fix: Fix failover detector with sentinel and tls streams --- lib/connectors/SentinelConnector/index.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/lib/connectors/SentinelConnector/index.ts b/lib/connectors/SentinelConnector/index.ts index a9d124f1..be40ef5b 100644 --- a/lib/connectors/SentinelConnector/index.ts +++ b/lib/connectors/SentinelConnector/index.ts @@ -165,15 +165,16 @@ export default class SentinelConnector extends AbstractConnector { resolved.port, endpointAddress ); + if (this.options.enableTLSForSentinelMode && this.options.tls) { Object.assign(resolved, this.options.tls); this.stream = createTLSConnection(resolved); + this.stream.once("secureConnect", this.initFailoverDetector.bind(this)); } else { this.stream = createConnection(resolved); + this.stream.once("connect", this.initFailoverDetector.bind(this)); } - this.stream.once("connect", () => this.initFailoverDetector()); - this.stream.once("error", (err) => { this.firstError = err; });