From 816bfec4a0b0316c4dcc2e42e4e7308f286ea49c Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Tue, 11 Feb 2020 21:41:23 +0300 Subject: [PATCH] various fixes for broker and messaging in server (#1187) * provide broker disconnect messages in server Signed-off-by: Vasiliy Tolstov * broker/eats: another fix Signed-off-by: Vasiliy Tolstov --- grpc.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/grpc.go b/grpc.go index dd2daef..5aed508 100644 --- a/grpc.go +++ b/grpc.go @@ -805,10 +805,7 @@ func (g *grpcServer) Start() error { return err } - baddr := config.Broker.Address() - bname := config.Broker.String() - - log.Logf("Broker [%s] Connected to %s", bname, baddr) + log.Logf("Broker [%s] Connected to %s", config.Broker.String(), config.Broker.Address()) } // announce self to the world @@ -876,6 +873,7 @@ func (g *grpcServer) Start() error { // close transport ch <- nil + log.Logf("Broker [%s] Disconnected from %s", config.Broker.String(), config.Broker.Address()) // disconnect broker config.Broker.Disconnect() }()