fix: send message to DLQ after correct number of attempts

Closes: #263
Admiral-Piett · Oct 3, 2024 · 95c4ab3 · 95c4ab3
1 parent 1a058d0
commit 95c4ab3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/app/gosqs/gosqs.go b/app/gosqs/gosqs.go
@@ -47,10 +47,10 @@ func PeriodicTasks(d time.Duration, quit <-chan struct{}) {
 							msg.Retry++
 							if queue.MaxReceiveCount > 0 &&
 								queue.DeadLetterQueue != nil &&
-								msg.Retry > queue.MaxReceiveCount {
+								msg.Retry >= queue.MaxReceiveCount {
 								queue.DeadLetterQueue.Messages = append(queue.DeadLetterQueue.Messages, *msg)
 								queue.Messages = append(queue.Messages[:i], queue.Messages[i+1:]...)
-								i++
+								i--
 							}
 						}
 					}