From beffa625f89378b75b6ba9b5f01704172793ec2f Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Tue, 6 Aug 2019 12:25:51 +0100 Subject: [PATCH] fix broker log line --- server/grpc/grpc.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/grpc/grpc.go b/server/grpc/grpc.go index f92048f1..de283043 100644 --- a/server/grpc/grpc.go +++ b/server/grpc/grpc.go @@ -719,10 +719,10 @@ func (g *grpcServer) Start() error { return err } - baddr := strings.Join(config.Broker.Options().Addrs, ",") + baddr := config.Broker.Address() bname := config.Broker.String() - log.Logf("Broker [%s] Listening on %s", bname, baddr) + log.Logf("Broker [%s] Connected to %s", bname, baddr) // announce self to the world if err := g.Register(); err != nil {