diff --git a/broker/http_broker.go b/broker/http_broker.go index 53dd48f1..41d80f5d 100644 --- 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()