From f07f7ac0d671e402c173298c656f78a8ac1e1639 Mon Sep 17 00:00:00 2001
From: "xinfei.wu" <jiyeyuran@gmail.com>
Date: Wed, 27 Feb 2019 12:28:03 +0800
Subject: [PATCH] fix: Broker's port is not registered.

Connecting to broker before registering.
---
 http.go | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/http.go b/http.go
index c063573..cc1a42a 100644
--- a/http.go
+++ b/http.go
@@ -247,8 +247,14 @@ func (h *httpServer) Start() error {
 		return errors.New("Server required http.Handler")
 	}
 
+	if err = opts.Broker.Connect(); err != nil {
+		return err
+	}
+
 	// register
-	h.Register()
+	if err = h.Register(); err != nil {
+		return err
+	}
 
 	go http.Serve(ln, handler)
 
@@ -286,7 +292,7 @@ func (h *httpServer) Start() error {
 		opts.Broker.Disconnect()
 	}()
 
-	return opts.Broker.Connect()
+	return nil
 }
 
 func (h *httpServer) Stop() error {