From 7aaca6f055539dd3ae890bf0faef1487c3520859 Mon Sep 17 00:00:00 2001 From: Matt Reiferson Date: Wed, 28 Dec 2016 09:48:30 -0800 Subject: [PATCH] nsqd: log when we can't get channels for pre-creation --- nsqd/nsqd.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/nsqd/nsqd.go b/nsqd/nsqd.go index 70dbd76ca..569b1a91d 100644 --- 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