Remove duplicate send

katanox · Jan 4, 2025 · 31334f6 · 31334f6
1 parent d9d0c41
commit 31334f6
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/core/src/main/kotlin/com/katanox/tabour/sqs/consumption/SqsPoller.kt b/core/src/main/kotlin/com/katanox/tabour/sqs/consumption/SqsPoller.kt
@@ -140,9 +140,6 @@ internal class SqsPoller(private val sqs: SqsClient) {
                     acknowledgeChannels[consumerIndex]
                         ?.channel
                         ?.send(ToBeAcknowledged(consumer.queueUri, message))
-                    acknowledgeChannels[consumerIndex]
-                        ?.channel
-                        ?.send(ToBeAcknowledged(consumer.queueUri, message))
                 } else {
                     val error = ConsumptionError.UnsuccessfulConsumption(message)
                     consumer.onError(error)