Don't return

2016-05-10 11:17:48 +01:00
parent aea81315d0
commit 9d629b5365
1 changed files with 0 additions and 1 deletions
--- 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