remove ignore error in method publish (#1075)

2020-01-04 01:24:20 +08:00 · 2020-01-04 01:24:20 +08:00 · 7098e59b5c
commit 7098e59b5c
parent 31362bc331
1 changed files with 1 additions and 2 deletions
--- a/broker/http_broker.go
+++ b/broker/http_broker.go
@ -533,8 +533,7 @@ func (h *httpBroker) Publish(topic string, msg *Message, opts ...PublishOption)
 	s, err := h.r.GetService(serviceName)
 	if err != nil {
 		h.RUnlock()
-		// ignore error
-		return nil
+		return err
 	}
 	h.RUnlock()