MaxConcurrency is causing too many open files when set to queue size passed in. Using default of 1 (#32)

thomaszurkan-optimizely · aliabbasrizvi · commit bbdc9040f677 · 2019-10-03T12:58:31.000-07:00
diff --git a/pkg/event/nsq_queue.go b/pkg/event/nsq_queue.go
@@ -177,7 +177,7 @@ func NewNSQueue(queueSize int, address string, startDaemon, startProducer, start
 
 	var p *snsq.Producer
 	var err error
-	nsqConfig := snsq.ProducerConfig{Address:NsqListenSpec, Topic:NsqTopic, MaxConcurrency:queueSize}
+	nsqConfig := snsq.ProducerConfig{Address:NsqListenSpec, Topic:NsqTopic}
 
 	if startProducer {
 		p, err = snsq.NewProducer(nsqConfig)
