Merge pull request #104 from ryanslade/reconnect-bug

consumer: Only add host address once on connection.
nsqio · Jan 27, 2015 · a6112d1 · a6112d1
2 parents b221991 + 5ade92a
commit a6112d1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/consumer.go b/consumer.go
@@ -496,7 +496,9 @@ func (r *Consumer) ConnectToNSQD(addr string) error {
 	if !pendingOk {
 		r.pendingConnections[addr] = conn
 	}
-	r.nsqdTCPAddrs = append(r.nsqdTCPAddrs, addr)
+	if idx := indexOf(addr, r.nsqdTCPAddrs); idx == -1 {
+		r.nsqdTCPAddrs = append(r.nsqdTCPAddrs, addr)
+	}
 	r.mtx.Unlock()
 
 	r.log(LogLevelInfo, "(%s) connecting to nsqd", addr)