From bb53516bcdc834e0217a6f972bf8b579ad948e06 Mon Sep 17 00:00:00 2001 From: Semih Buyukgungor Date: Mon, 22 Jul 2024 16:34:13 +0300 Subject: [PATCH] Return the error if TLS config fails in Rabbitmq scaler (#5964) Signed-off-by: semihbkgr --- pkg/scalers/rabbitmq_scaler.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/scalers/rabbitmq_scaler.go b/pkg/scalers/rabbitmq_scaler.go index 6037aa45944..be2ac66995f 100644 --- a/pkg/scalers/rabbitmq_scaler.go +++ b/pkg/scalers/rabbitmq_scaler.go @@ -454,9 +454,10 @@ func getConnectionAndChannel(host string, meta *rabbitMQMetadata) (*amqp.Connect var err error if meta.enableTLS { tlsConfig, configErr := kedautil.NewTLSConfigWithPassword(meta.cert, meta.key, meta.keyPassword, meta.ca, meta.unsafeSsl) - if configErr == nil { - conn, err = amqp.DialTLS(host, tlsConfig) + if configErr != nil { + return nil, nil, configErr } + conn, err = amqp.DialTLS(host, tlsConfig) } else { conn, err = amqp.Dial(host) }