From 6937857bf846ec0cd672cb2e61027b4b00b39a2d Mon Sep 17 00:00:00 2001 From: spike Date: Sun, 13 Nov 2022 15:32:12 +0800 Subject: [PATCH] Change error message and comment Signed-off-by: spike --- pubsub/rabbitmq/metadata.go | 2 +- pubsub/tls.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pubsub/rabbitmq/metadata.go b/pubsub/rabbitmq/metadata.go index 6a8f45c18..13d730432 100644 --- a/pubsub/rabbitmq/metadata.go +++ b/pubsub/rabbitmq/metadata.go @@ -104,7 +104,7 @@ func createMetadata(pubSubMetadata pubsub.Metadata, log logger.Logger) (*metadat if result.connectionString != "" { uri, err := amqp.ParseURI(result.connectionString) if err != nil { - return &result, err + return &result, fmt.Errorf("%s invalid connection string: %s, err: %w", errorMessagePrefix, result.connectionString, err) } result.protocol = uri.Scheme } diff --git a/pubsub/tls.go b/pubsub/tls.go index eebd88463..848ac4d67 100644 --- a/pubsub/tls.go +++ b/pubsub/tls.go @@ -20,7 +20,7 @@ const ( ClientKey = "clientKey" ) -// TLS takes a metadata object and returns the TlsCfg configured. +// TLS takes a metadata object and returns the TLSProperties configured. func TLS(metadata map[string]string) (TLSProperties, error) { cfg := TLSProperties{}