weird thing

gistfile1.go

/*
For readersCount == 4, you might see 4 "added reader" (0 through 3) or just one, or three, etc. Like it's blocking somewhere... The readers that do initialize process messages just fine. All of the nsqlookupd hosts respond to /ping.
*/

for i := 0; i < readersCount; i++ {

	r, err := nsq.NewReader(topic, channel)

	if err != nil {
		log.Fatalln("nsq.NewReader:", err)
	}

	r.SetMaxInFlight(2500)

	for j := 0; j < workersPerReader; j++ {
		r.AddHandler(w)
	}

	for _, host := range hosts {

		err := r.ConnectToLookupd(host)

		if err != nil {
			log.Fatalf("ConnectToLookupd @ %s: %s\n", host, err)
		}
	}

	fmt.Println("added reader", i)

	readers[i] = r
}