From 96645c7b519cd9d47c0d9e5f4c048d1668afaf9e Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Fri, 6 Mar 2015 14:55:33 -0800 Subject: [PATCH] Only use scheme and host of redirected URL --- messaging/client.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/messaging/client.go b/messaging/client.go index 4a7053dab6..02140cbaef 100644 --- a/messaging/client.go +++ b/messaging/client.go @@ -92,15 +92,18 @@ func (c *Client) LeaderURL() *url.URL { } } -// SetLeaderURL sets the explicit broker leader. +// SetLeaderURL sets the explicit broker leader. The leader is set to the scheme, host, +// and port (if any) contained in the URL. All other components of the URL are ignored. func (c *Client) SetLeaderURL(u *url.URL) { c.mu.Lock() defer c.mu.Unlock() if u == nil { return } - c.Logger.Printf("setting broker leader to %s", u.String()) - c.config.Leader = u + + v := &url.URL{Scheme: u.Scheme, Host: u.Host} + c.Logger.Printf("setting broker leader to %s", v.String()) + c.config.Leader = v } // SetLogOutput sets writer for all Client log output.