connector-aws-sqs/com.river.connector.aws.sqs

Package-level declarations

Functions

Link copied to clipboard
infix fun <Error class: unknown class>.acknowledgeWith(acknowledgment: Acknowledgment): <Error class: unknown class>

Util function to create a MessageAcknowledgment from a Message and an Acknowledgment.

Link copied to clipboard
fun <Error class: unknown class>.acknowledgmentMessageFlow(queue: SqsQueue, upstream: Flow<MessageAcknowledgment<Acknowledgment>>, concurrency: Int = 1, groupStrategy: GroupStrategy = GroupStrategy.TimeWindow(10, 250.milliseconds)): Flow<MessageAcknowledgmentResult>

Creates a flow that processes acknowledgments for messages in an Amazon Simple Queue Service (SQS) queue.

Link copied to clipboard
fun <Error class: unknown class>.changeMessageVisibilityFlow(queue: SqsQueue, upstream: Flow<MessageAcknowledgment<Acknowledgment.ChangeMessageVisibility>>, concurrency: Int = 1, groupStrategy: GroupStrategy = GroupStrategy.TimeWindow(10, 250.milliseconds)): Flow<ChangeMessageVisibilityResult>

Creates a flow that efficiently changes the visibility of messages in an Amazon Simple Queue Service (SQS) queue.

Link copied to clipboard
fun <Error class: unknown class>.deleteMessagesFlow(queue: SqsQueue, upstream: Flow<MessageAcknowledgment<Acknowledgment.Delete>>, concurrency: Int = 1, groupStrategy: GroupStrategy = GroupStrategy.TimeWindow(10, 250.milliseconds)): Flow<MessageDeleteResult>

Creates a flow that deletes messages from an Amazon Simple Queue Service (SQS) queue.

Link copied to clipboard
fun <Error class: unknown class>.onMessage(queue: SqsQueue, concurrency: Int = 1, receiveConfiguration: ReceiveConfiguration.() -> Unit = {}, commitConfiguration: CommitConfiguration.() -> Unit = {}, onError: OnError = OnError.Retry(250.milliseconds), onMessage: suspend (<Error class: unknown class>) -> Acknowledgment): Job

This function is a high-level abstraction that combines receiving messages, processing them, and sending acknowledgments. It is built on top of the receiveMessagesAsFlow and acknowledgmentMessageFlow functions.

Link copied to clipboard
fun <Error class: unknown class>.onMessages(queue: SqsQueue, concurrency: Int = 1, groupStrategy: GroupStrategy = GroupStrategy.TimeWindow(10, 250.milliseconds), receiveConfiguration: ReceiveConfiguration.() -> Unit = {}, commitConfiguration: CommitConfiguration.() -> Unit = {}, onError: OnError = OnError.Retry(250.milliseconds), onMessages: suspend (List<<Error class: unknown class>>) -> List<MessageAcknowledgment<Acknowledgment>>): Job

This function is a high-level abstraction that combines receiving messages, processing them, and sending acknowledgments. It is built on top of the receiveMessagesAsFlow and acknowledgmentMessageFlow functions.

Link copied to clipboard
inline fun <Error class: unknown class>.receiveMessagesAsFlow(concurrency: ConcurrencyStrategy = ConcurrencyStrategy.disabled, stopOnEmptyList: Boolean = false, crossinline builder: suspend <Error class: unknown class>.() -> Unit): Flow<<Error class: unknown class>>

Continuously receives messages from an Amazon Simple Queue Service (SQS) queue using the provided SqsClient. The received messages are returned as a Flow of Message objects.

Link copied to clipboard
fun <Error class: unknown class>.sendMessageFlow(queue: SqsQueue, upstream: Flow<<Error class: unknown class>>, concurrency: Int = 1, groupStrategy: GroupStrategy = GroupStrategy.TimeWindow(10, 250.milliseconds)): Flow<SendMessageResult>

Sends messages to an Amazon Simple Queue Service (SQS) queue efficiently using the provided SqsClient. Messages are collected from an upstream Flow of SendMessageRequest objects and sent in batches for optimal performance.