From 3a789327adf9806b8bdcb4d87ed50e3f72bb8e7e Mon Sep 17 00:00:00 2001 From: raihankhan Date: Thu, 30 May 2024 12:38:05 +0600 Subject: [PATCH] Fix http url Signed-off-by: raihankhan --- rabbitmq/http_client.go | 2 +- rabbitmq/kubedb_client_builder.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/rabbitmq/http_client.go b/rabbitmq/http_client.go index e8fd1d18..26f19e70 100644 --- a/rabbitmq/http_client.go +++ b/rabbitmq/http_client.go @@ -35,7 +35,7 @@ func (c *HTTPClient) IsAllNodesRunningInCluster(replicas int) (bool, error) { } for _, node := range nodes { if !node.IsRunning { - klog.Error(err, fmt.Sprintf("Node: %s is not running", node.Name)) + klog.Error(fmt.Sprintf("Node: %s is not running", node.Name)) return false, nil } } diff --git a/rabbitmq/kubedb_client_builder.go b/rabbitmq/kubedb_client_builder.go index 20fbc100..a6d8f2fd 100644 --- a/rabbitmq/kubedb_client_builder.go +++ b/rabbitmq/kubedb_client_builder.go @@ -158,7 +158,7 @@ func (o *KubeDBClientBuilder) GetAMQPconnURL(username string, password string) s } func (o *KubeDBClientBuilder) GetHTTPconnURL() string { - return fmt.Sprintf("http://%s.%s.svc.cluster.local:%d/", o.db.OffshootName(), o.db.Namespace, api.RabbitMQManagementUIPort) + return fmt.Sprintf("http://%s.%s.svc.cluster.local:%d", o.db.OffshootName(), o.db.Namespace, api.RabbitMQManagementUIPort) } // RabbitMQ server have a default virtual host "/"