Merge pull request nsqio#115 from judwhite/master

remove unnecessary check on pendingOk
arussellsaw · Feb 10, 2015 · 4b786ba · 4b786ba
2 parents 160dc75 + 4f5779c
commit 4b786ba
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/consumer.go b/consumer.go
@@ -513,9 +513,7 @@ func (r *Consumer) ConnectToNSQD(addr string) error {
 		r.mtx.Unlock()
 		return ErrAlreadyConnected
 	}
-	if !pendingOk {
-		r.pendingConnections[addr] = conn
-	}
+	r.pendingConnections[addr] = conn
 	if idx := indexOf(addr, r.nsqdTCPAddrs); idx == -1 {
 		r.nsqdTCPAddrs = append(r.nsqdTCPAddrs, addr)
 	}