fix: connect and disconnect broker

2018-12-20 11:31:36 +08:00
parent 532edc786f
commit b7e57d6192
1 changed files with 3 additions and 1 deletions
--- 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 {