From c5dd737568dd2167dfd244c8c7a066198f8d1c3c Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Wed, 10 Jul 2019 19:58:30 +0100
Subject: [PATCH] Add back in broker address

---
 broker/broker.go     | 1 +
 server/rpc_server.go | 3 +--
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/broker/broker.go b/broker/broker.go
index b7b9dcb0..2871e818 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -5,6 +5,7 @@ package broker
 type Broker interface {
 	Init(...Option) error
 	Options() Options
+	Address() string
 	Connect() error
 	Disconnect() error
 	Publish(topic string, m *Message, opts ...PublishOption) error
diff --git a/server/rpc_server.go b/server/rpc_server.go
index 8bb7b547..696151e3 100644
--- a/server/rpc_server.go
+++ b/server/rpc_server.go
@@ -498,10 +498,9 @@ func (s *rpcServer) Start() error {
 		return err
 	}
 
-	baddr := strings.Join(config.Broker.Options().Addrs, ",")
 	bname := config.Broker.String()
 
-	log.Logf("Broker [%s] Connected to %s", bname, baddr)
+	log.Logf("Broker [%s] Connected to %s", bname, config.Broker.Address())
 
 	// use RegisterCheck func before register
 	if err = s.opts.RegisterCheck(s.opts.Context); err != nil {