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 "/"