Return original messages when autoDelete is used just in case message…

… deletion retries are exhausted
zio · Jan 8, 2025 · b3dafd7 · b3dafd7
1 parent 9dae16e
commit b3dafd7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zio-sqs/src/main/scala/zio/sqs/SqsStream.scala b/zio-sqs/src/main/scala/zio/sqs/SqsStream.scala
@@ -44,7 +44,7 @@ object SqsStream {
       .flattenChunks
       .mapChunksZIO { messages =>
         // NOTE: At-most-once semantics (when autoDelete=true)
-        if (settings.autoDelete) deleteMessageBatch(queueUrl, messages)
+        if (settings.autoDelete) deleteMessageBatch(queueUrl, messages).as(messages)
         else Exit.succeed(messages)
       }
   }