Packages

object SqsAckSink

Java API to create acknowledging 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 create(queueUrl: String, settings: SqsAckSettings, sqsClient: SqsAsyncClient): Sink[MessageAction, CompletionStage[Done]]

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

  2. def createGrouped(queueUrl: String, settings: SqsAckGroupedSettings, sqsClient: SqsAsyncClient): Sink[MessageAction, CompletionStage[Done]]

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