mreiferson

var exitSelectCases []reflect.SelectCase

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++ {