Merge pull request #31 from practo/sqs-dlq-fix

Long poll only when messages is also 0
practo · Sep 14, 2019 · 68c8f3d · 68c8f3d
2 parents ab7e4e1 + a4f248c
commit 68c8f3d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/queue/sqs.go b/pkg/queue/sqs.go
@@ -241,7 +241,7 @@ func (s *SQS) waitForShortPollInterval() {
 }
 
 func (s *SQS) poll(key string, queueSpec QueueSpec) {
-	if queueSpec.workers == 0 {
+	if queueSpec.workers == 0 && queueSpec.messages == 0 {
 		s.queues.updateIdleWorkers(key, -1)
 
 		// If there are no workers running we do a long poll to find a job(s)