From b7e57d6192374592eff620f02bb5d6e7bec58d35 Mon Sep 17 00:00:00 2001
From: "xinfei.wu" <xinfei.wu@qq.com>
Date: Thu, 20 Dec 2018 11:31:36 +0800
Subject: [PATCH] fix: connect and disconnect broker

---
 http.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/http.go b/http.go
index c5633f5..2705c13 100644
--- a/http.go
+++ b/http.go
@@ -251,9 +251,11 @@ func (h *httpServer) Start() error {
 	go func() {
 		ch := <-h.exit
 		ch <- ln.Close()
+
+		opts.Broker.Disconnect()
 	}()
 
-	return nil
+	return opts.Broker.Connect()
 }
 
 func (h *httpServer) Stop() error {