Update registration_db.go

nsqio · Oct 12, 2017 · 1543cfe · 1543cfe
1 parent 27499a5
commit 1543cfe
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/nsqlookupd/registration_db.go b/nsqlookupd/registration_db.go
@@ -76,6 +76,7 @@ func (r *RegistrationDB) AddProducer(k Registration, p *Producer) bool {
 	for _, producer := range producers {
 		if producer.peerInfo.id == p.peerInfo.id {
 			found = true
+			break
 		}
 	}
 	if found == false {