diff --git a/broker/http_broker.go b/broker/http_broker.go
index ea54aa8c..75a749cb 100644
--- a/broker/http_broker.go
+++ b/broker/http_broker.go
@@ -382,7 +382,6 @@ func (h *httpBroker) Publish(topic string, msg *Message, opts ...PublishOption)
 		node := service.Nodes[rand.Int()%len(service.Nodes)]
 		// publish async
 		go fn(node, b)
-		return nil
 	}
 
 	return nil