diff --git a/CHANGELOG.md b/CHANGELOG.md index 25ef88e5827..2a3d6fae913 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -68,6 +68,7 @@ Here is an overview of all new **experimental** features: ### Improvements +- **RabbitMQ Scaler** Add connection name for AMQP - TODO ([#XXX](https://github.com/kedacore/keda/issues/XXX)) ### Fixes diff --git a/pkg/scalers/rabbitmq_scaler.go b/pkg/scalers/rabbitmq_scaler.go index f0c1320f01e..e402252809c 100644 --- a/pkg/scalers/rabbitmq_scaler.go +++ b/pkg/scalers/rabbitmq_scaler.go @@ -456,14 +456,13 @@ func getConnectionAndChannel(host string, meta *rabbitMQMetadata) (*amqp.Connect } if meta.enableTLS { - tlsConfig, err := kedautil.NewTLSConfigWithPassword(meta.cert, meta.key, meta.keyPassword, meta.ca, meta.unsafeSsl) if err != nil { return nil, nil, err } amqpConfig.TLSClientConfig = tlsConfig - } + } conn, err := amqp.DialConfig(host, amqpConfig) if err != nil {