Merge pull request nsqio#15 from hailocab/fix-lookup-err

Fix bounds err when removing lookupds.
HailoOSS · Jan 30, 2015 · d2f55f5 · d2f55f5
2 parents 514cbea + 16845ac
commit d2f55f5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/consumer.go b/consumer.go
@@ -382,6 +382,9 @@ exit:
 // keeping track of which one was last used
 func (r *Consumer) nextLookupdEndpoint() string {
 	r.mtx.RLock()
+	if r.lookupdQueryIndex >= len(r.lookupdHTTPAddrs) {
+		r.lookupdQueryIndex = 0
+	}
 	addr := r.lookupdHTTPAddrs[r.lookupdQueryIndex]
 	num := len(r.lookupdHTTPAddrs)
 	r.mtx.RUnlock()