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; });