nsqd: log when we can't get channels for pre-creation

nsqio · Dec 28, 2016 · 7aaca6f · 7aaca6f
1 parent bdb2919
commit 7aaca6f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/nsqd/nsqd.go b/nsqd/nsqd.go
@@ -444,7 +444,10 @@ func (n *NSQD) GetTopic(topicName string) *Topic {
 	// this makes sure that any message received is buffered to the right channels
 	lookupdHTTPAddrs := n.lookupdHTTPAddrs()
 	if len(lookupdHTTPAddrs) > 0 {
-		channelNames, _ := n.ci.GetLookupdTopicChannels(t.name, lookupdHTTPAddrs)
+		channelNames, err := n.ci.GetLookupdTopicChannels(t.name, lookupdHTTPAddrs)
+		if err != nil {
+			n.logf("ERROR: failed to get channels for pre-creation for topic %s - %s", t.name, err)
+		}
 		for _, channelName := range channelNames {
 			if strings.HasSuffix(channelName, "#ephemeral") {
 				// we don't want to pre-create ephemeral channels