From 88ef21ba9e4f596d575422b744eaece5384a52db Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Thu, 13 May 2021 10:59:29 +0300 Subject: [PATCH] fix broker disconnect Signed-off-by: Vasiliy Tolstov --- http.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/http.go b/http.go index f526e02..7586408 100644 --- a/http.go +++ b/http.go @@ -556,8 +556,6 @@ func (h *httpServer) Start() error { } } - ch <- ts.Close() - // deregister if err := h.Deregister(); err != nil { config.Logger.Errorf(config.Context, "Server deregister error: %s", err) @@ -566,6 +564,9 @@ func (h *httpServer) Start() error { if err := config.Broker.Disconnect(config.Context); err != nil { config.Logger.Errorf(config.Context, "Broker disconnect error: %s", err) } + + ch <- ts.Close() + }() return nil