Return the error if TLS config fails in Rabbitmq scaler (#5964)

Signed-off-by: semihbkgr <buyukgungorsemih@gmail.com>
kedacore · Jul 22, 2024 · bb53516 · bb53516
1 parent 817821f
commit bb53516
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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)
 	}