Merge pull request nsqio#982 from jehiah/nsqadmin_ephemeral_982

nsqadmin: error querying nsqd stats for #ephemeral channel
judwhite · Jan 8, 2018 · ff26ab4 · ff26ab4
2 parents 25bc210 + 94e070b
commit ff26ab4
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/internal/clusterinfo/data.go b/internal/clusterinfo/data.go
@@ -450,7 +450,7 @@ func (c *ClusterInfo) GetNSQDTopicProducers(topic string, nsqdHTTPAddrs []string
 		go func(addr string) {
 			defer wg.Done()
 
-			endpoint := fmt.Sprintf("http://%s/stats?format=json&topic=%s", addr, topic)
+			endpoint := fmt.Sprintf("http://%s/stats?format=json&topic=%s", addr, url.QueryEscape(topic))
 			c.logf("CI: querying nsqd %s", endpoint)
 
 			var statsResp statsRespType
@@ -552,9 +552,9 @@ func (c *ClusterInfo) GetNSQDStats(producers Producers, selectedTopic string, se
 
 			endpoint := fmt.Sprintf("http://%s/stats?format=json", addr)
 			if selectedTopic != "" {
-				endpoint += "&topic=" + selectedTopic
+				endpoint += "&topic=" + url.QueryEscape(selectedTopic)
 				if selectedChannel != "" {
-					endpoint += "&channel=" + selectedChannel
+					endpoint += "&channel=" + url.QueryEscape(selectedChannel)
 				}
 			}