v0.7.1

What's Changed

• add test for deleteMessageBatchSink by @calvinlfer in #774
• Update README.md by @zio-assistant in #775
• Update README.md by @zio-assistant in #776
• Update scala-library to 2.13.16 by @scala-steward in #778
• Update sbt-scalafmt to 2.5.4 by @scala-steward in #779
• Update zio-aws-netty, zio-aws-sqs to 7.28.29.16 by @scala-steward in #780

Full Changelog: v0.7.0...v0.7.1

v0.7.0

What's Changed

We have added a new high level API called SqsStream.consumeChunkAtLeastOnce inspired by FS2 Kafka's consumeChunk API. This new API allows you to focus on processing a chunk of messages and we take of deleting the messages once you have processed them successfully. Failure to process messages will prevent the messages from being deleted from the SQS queue so you can receive it again (hence at-least-once). If your messages take long to process (i.e. past the visibility timeout), you can leverage the automatic extension feature (on by default) which will automatically submit visibility extension messages for the chunk of messages you are working on so that the messages won't reappear back on the queue for other consumers to process limiting the chance of multiple consumers working on the same message.

The new API looks lke this:

val consumerExample =
    SqsStream.consumeChunkAtLeastOnce(
      queueUrl = queueUrl,
      settings = SqsStreamSettings.default
      extensionSettings = SqsMessageLifetimeExtensionSettings.default
    ) { (messages: Chunk[Message.ReadOnly]) =>
        ZIO.debug(s"working on $messages").unit
    }

As long as your ZIO effect successfully completes, the API will take care of deleting the messages (using batching) and pulling the next set of messages to process.

We didn't forget about SqsStream and performance improvements have been applied to preserve chunking. If you use autoDelete=true (which is at-most-once delivery), we also perform batch deletes and reduce the number of API calls made.

We have also added SqsStream.deleteMessageBatchSink to help facilitate at-least-once delivery semantics for users of SqsStream so you can use SqsStream with autoDelete=false, process your messages as you see fit and then hook your stream to thedeleteMessageBatchSink ZSink to delete messages from the queue.

Here is an example:

val consumerStreamExample =
  SqsStream(queueUrl, SqsStreamSettings.default.withAutoDelete(false))
    .tap(message => ZIO.debug(s"processing $message here")) // for illustration purposes only
    .run(SqsStream.deleteMessageBatchSink(queueUrl))

We've also added extendMessageLifetime and batch variants so that you can utilize these methods if message processing goes past the visibility timeout. For batch methods like deleteMessageBatch and extendMessageLifetimeBatch, we take care to perform retries since a batch request can come back with individual message failures that need to be retried. Note that if your extendMessageLifetimeBatch is invoked too late (past the visibility timeout duration), you will get errors since you cannot keep the message invisible from the queue and you will be forced to reprocess the message. We make use of extendMessageLifetimeBatch inside consumeChunkAtLeastOnce

Note: We've made minor breaking changes to SqsSettings to adhere to the AWS defaults and not override them if you don't specify them. We've also removed the R type parameter in Producer.make since requirements are contravariant.

More information about testing the new changes against AWS SQS and AWS SQS FIFO can be found in #773

Full Changelog: v0.6.5...v0.7.0

v0.6.5

What's Changed

• Update zio, zio-streams, zio-test, ... to 2.1.12 by @scala-steward in #748
• Update README.md by @zio-assistant in #750
• Update zio-aws-netty, zio-aws-sqs to 7.28.29.4 by @scala-steward in #749
• Update zio-aws-netty, zio-aws-sqs to 7.28.29.5 by @scala-steward in #752
• Update zio, zio-streams, zio-test, ... to 2.1.13 by @scala-steward in #751
• Update zio-aws-netty, zio-aws-sqs to 7.28.29.6 by @scala-steward in #753
• Update sbt, scripted-plugin to 1.10.6 by @scala-steward in #755
• Update zio-aws-netty, zio-aws-sqs to 7.28.29.7 by @scala-steward in #754
• Update zio-aws-netty, zio-aws-sqs to 7.28.29.8 by @scala-steward in #756

Full Changelog: v0.6.4...v0.6.5

v0.6.4

What's Changed

• Update zio-aws-netty, zio-aws-sqs to 7.28.29.3 by @scala-steward in #745
• Update sbt, scripted-plugin to 1.10.5 by @scala-steward in #744
• Update README.md by @zio-assistant in #747

Full Changelog: v0.6.3...v0.6.4

v0.6.3

What's Changed

• Update zio-aws-netty, zio-aws-sqs to 7.28.29.2 by @scala-steward in #742
• Update README.md by @zio-assistant in #743

Full Changelog: v0.6.2...v0.6.3

v0.6.2

What's Changed

• Update scala-library to 2.12.20 by @scala-steward in #721
• Update README.md by @zio-assistant in #722
• Update elasticmq-core, elasticmq-rest-sqs to 1.6.8 by @scala-steward in #723
• Update sbt to 1.10.2 by @scala-steward in #724
• Update scala3-library to 3.3.4 by @scala-steward in #726
• Update scala-library to 2.13.15 by @scala-steward in #725
• Update zio, zio-streams, zio-test, ... to 2.1.11 by @scala-steward in #728
• Update sbt-ci-release to 1.7.0 by @scala-steward in #727
• Update sbt-ci-release to 1.8.0 by @scala-steward in #729
• Update zio-aws-netty, zio-aws-sqs to 7.28.26.1 by @scala-steward in #736
• Update sbt, scripted-plugin to 1.10.3 by @scala-steward in #735
• Update elasticmq-core, elasticmq-rest-sqs to 1.6.9 by @scala-steward in #737
• Update sbt-ci-release to 1.9.0 by @scala-steward in #732
• ElasticMQ supports Scala 3 LTS so stop using cross version by @calvinlfer in #738
• Update sbt, scripted-plugin to 1.10.4 by @scala-steward in #741
• Update zio-aws-netty, zio-aws-sqs to 7.28.29.1 by @scala-steward in #740

New Contributors

• @zio-assistant made their first contribution in #722

Full Changelog: v0.6.1...v0.6.2

v0.6.1

What's Changed

• Update libraries to latest by @calvinlfer in #720

New Contributors

• @calvinlfer made their first contribution in #720

Full Changelog: v0.6.0...v0.6.1

v0.6.0

This release brings support for Scala 3.

v0.5.0

This version brings support for ZIO 2.0 final.

v0.4.3

This version only updates dependencies: zio-aws to 3.17.100.3 and zio to 1.0.13 (#598 by @lmlynik).