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

Package-level declarations

Types

data class AcknowledgmentResult<T : SdkResponse>(val message: Message, val acknowledgment: Acknowledgment, val response: SdkResponse?)

CommitConfiguration

class CommitConfiguration

MessageAcknowledgment

data class MessageAcknowledgment<T : Acknowledgment>(val message: Message, val acknowledgment: T)

OnError

interface OnError

ReceiveConfiguration

class ReceiveConfiguration

ReceiveMessageRequestBuilder

class ReceiveMessageRequestBuilder(var queueUrl: String? = null, var waitTimeSeconds: Int = 20, var maxNumberOfMessages: Int = 10, var visibilityTimeout: Int = 30, var receiveRequestAttemptId: String? = null, var messageAttributeNames: List<String> = emptyList(), var attributeNames: List<QueueAttributeName> = emptyList())

SendMessageRequest

data class SendMessageRequest(val body: String, val delaySeconds: Int = 0, val messageAttributes: Map<String, MessageAttributeValue> = emptyMap(), val id: String = UUID.randomUUID().toString())

SendMessageResponse

interface SendMessageResponse