set broker address on Init

2018-08-18 17:28:58 +01:00
parent a0d3917832
commit 9d3cb65daa
1 changed files with 4 additions and 1 deletions
--- a/broker/http_broker.go
+++ b/broker/http_broker.go
@@ -276,7 +276,6 @@ func (h *httpBroker) Address() string {
 }

 func (h *httpBroker) Connect() error {
-
 	h.RLock()
 	if h.running {
 		h.RUnlock()
@@ -397,6 +396,10 @@ func (h *httpBroker) Init(opts ...Option) error {
 		o(&h.opts)
 	}

+	if len(h.opts.Addrs) > 0 && len(h.opts.Addrs[0]) > 0 {
+		h.address = h.opts.Addrs[0]
+	}
+
 	if len(h.id) == 0 {
 		h.id = "broker-" + uuid.NewUUID().String()
 	}