From b3f501e78927e838b2d60f15eeb6d8eb79cab649 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Sun, 7 Jul 2019 12:33:47 +0100 Subject: [PATCH] strip broker address --- grpc.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/grpc.go b/grpc.go index 6575d3b..75b8823 100644 --- a/grpc.go +++ b/grpc.go @@ -714,7 +714,10 @@ func (g *grpcServer) Start() error { return err } - log.Logf("Broker [%s] Listening on %s", config.Broker.String(), config.Broker.Address()) + baddr := strings.Join(config.Broker.Options().Addrs, ",") + bname := config.Broker.String() + + log.Logf("Broker [%s] Listening on %s", bname, baddr) // announce self to the world if err := g.Register(); err != nil {