From 9d629b5365e4b62dcfeea6c156be6f5051c5a217 Mon Sep 17 00:00:00 2001 From: Asim Date: Tue, 10 May 2016 11:17:48 +0100 Subject: [PATCH] Don't return --- broker/http_broker.go | 1 - 1 file changed, 1 deletion(-) 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