From 13bf2bbb1e812a22b912adb392ab254526e00b7c Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Sat, 13 May 2023 16:09:21 +0300
Subject: [PATCH] check subscribe errors

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 http.go | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/http.go b/http.go
index e42fe63..48251c7 100644
--- a/http.go
+++ b/http.go
@@ -378,6 +378,17 @@ func (h *Server) Register() error {
 	}
 
 	h.Lock()
+
+	h.registered = true
+	h.rsvc = service
+	h.Unlock()
+
+	return nil
+}
+
+func (h *Server) subscribe() error {
+	config := h.opts
+
 	for sb := range h.subscribers {
 		handler := h.createSubHandler(sb, config)
 		var opts []broker.SubscribeOption
@@ -401,10 +412,6 @@ func (h *Server) Register() error {
 		h.subscribers[sb] = []broker.Subscriber{sub}
 	}
 
-	h.registered = true
-	h.rsvc = service
-	h.Unlock()
-
 	return nil
 }
 
@@ -539,6 +546,10 @@ func (h *Server) Start() error {
 		}
 	}
 
+	if err := h.subscribe(); err != nil {
+		return err
+	}
+
 	fn := handler
 
 	if h.opts.Context != nil {