From da8a62dccaf0cfa04f5e56323dd56b77f931a909 Mon Sep 17 00:00:00 2001 From: Thomas Zurkan Date: Thu, 3 Oct 2019 12:53:07 -0700 Subject: [PATCH] MaxConcurrency is causing too many open files when set to queue size passed in. Using default of 1 --- pkg/event/nsq_queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/event/nsq_queue.go b/pkg/event/nsq_queue.go index f350add8..1faad0ca 100644 --- 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)