Skip to content

Commit

Permalink
Fix http url
Browse files Browse the repository at this point in the history
Signed-off-by: raihankhan <[email protected]>
  • Loading branch information
raihankhan committed May 31, 2024
1 parent cdf42a6 commit 3a78932
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion rabbitmq/http_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
}
Expand Down
2 changes: 1 addition & 1 deletion rabbitmq/kubedb_client_builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 "/"
Expand Down

0 comments on commit 3a78932

Please sign in to comment.