From 35364b037ba56410ccb502c23bb8509472b9d910 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 --- grpc.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/grpc.go b/grpc.go index f92048f..de28304 100644 --- a/grpc.go +++ b/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 {