Packages

object SqsAckSink

Scala API to create acknowledging SQS sinks.

Source
SqsAckSink.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SqsAckSink
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apply(queueUrl: String, settings: SqsAckSettings = SqsAckSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[MessageAction, Future[Done]]

    creates a Sink for ack a single SQS message at a time using an software.amazon.awssdk.services.sqs.SqsAsyncClient.

  2. def grouped(queueUrl: String, settings: SqsAckGroupedSettings = SqsAckGroupedSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[MessageAction, Future[Done]]

    creates a Sink for ack grouped SQS messages using an software.amazon.awssdk.services.sqs.SqsAsyncClient.