http4k-connect-amazon-sqs/org.http4k.connect.amazon.sqs.action

Package-level declarations

Types

@JsonSerializable

data class CreatedQueue(val QueueUrl: Uri)

@JsonSerializable

data class CreateQueue(val QueueName: QueueName, val Tags: Map<String, String>? = null, val Attributes: Map<String, String>? = null) : SQSAction<CreatedQueue, CreatedQueue>

DeleteMessage

@JsonSerializable

data class DeleteMessage(@Json(name = "QueueUrl") val queueUrl: Uri, @Json(name = "ReceiptHandle") val receiptHandle: ReceiptHandle, val expires: ZonedDateTime? = null) : SQSAction<Unit, Unit>

DeleteMessageBatch

@JsonSerializable

data class DeleteMessageBatch(@Json(name = "QueueUrl") val queueUrl: Uri, @Json(name = "Entries") val entries: List<DeleteMessageBatchEntry>) : SQSAction<List<SQSMessageId>, DeleteMessageBatchResponse>

DeleteMessageBatchEntry

@JsonSerializable

data class DeleteMessageBatchEntry(val Id: SQSMessageId, val ReceiptHandle: ReceiptHandle)

DeleteMessageBatchResponse

@JsonSerializable

data class DeleteMessageBatchResponse(val Failed: List<BatchResultErrorEntry>?, val Successful: List<DeleteMessageBatchResultEntry>)

DeleteMessageBatchResultEntry

@JsonSerializable

data class DeleteMessageBatchResultEntry(val Id: SQSMessageId)

DeleteMessageData

@JsonSerializable

data class DeleteMessageData(val QueueUrl: Uri, val ReceiptHandle: ReceiptHandle)

DeleteQueue

@JsonSerializable

data class DeleteQueue(val QueueUrl: Uri, val expires: ZonedDateTime? = null) : SQSAction<Unit, Unit>

GetQueueAttributes

@JsonSerializable

data class GetQueueAttributes(@Json(name = "QueueUrl") val queueUrl: Uri, @Json(name = "AttributeNames") val attributes: List<String>? = null) : SQSAction<QueueAttributes, QueueAttributes>

ListQueues

@JsonSerializable

data class ListQueues(val MaxResults: Int? = null, val NextToken: String? = null, val QueueNamePrefix: String? = null) : SQSAction<List<Uri>, ListQueuesResponse>

ListQueuesResponse

@JsonSerializable

data class ListQueuesResponse(val NextToken: String? = null, val QueueUrls: List<Uri>)

QueueAttributes

@JsonSerializable

data class QueueAttributes(@Json(name = "Attributes") val attributes: Map<String, String> = emptyMap())

ReceiveMessage

@JsonSerializable

data class ReceiveMessage(@Json(name = "QueueUrl") val queueUrl: Uri, @Json(name = "MaxNumberOfMessages") val maxNumberOfMessages: Int? = null, @Json(name = "VisibilityTimeout") val visibilityTimeout: Int? = null, val expires: ZonedDateTime? = null, @Json(name = "WaitTimeSeconds") val waitTimeSeconds: Int? = null, @Json(name = "MessageAttributeNames") val messageAttributes: List<String>? = null, @Json(name = "EeceiveRequestAttemptId") val receiveRequestAttemptId: String? = null, @Json(name = "AttributeNames") val attributeNames: List<String>? = null) : SQSAction<List<SQSMessage>, ReceiveMessageResponse>

ReceiveMessageResponse

@JsonSerializable

data class ReceiveMessageResponse(val Messages: List<SQSMessage>?)

SendMessage

@JsonSerializable

data class SendMessage(@Json(name = "QueueUrl") val queueUrl: Uri, @Json(name = "MessageBody") val messageBody: String, @Json(name = "DelaySeconds") val delaySeconds: Int? = null, @Json(name = "MessageDeduplicationId") val messageDeduplicationId: String? = null, @Json(name = "MessageGroupId") val messageGroupId: String? = null, @Json(name = "MessageAttributes") val messageAttributes: Map<String, MessageFieldsDto>? = null, @Json(name = "MessageSystemAttributes") val messageSystemAttributes: Map<String, MessageFieldsDto>? = null) : SQSAction<SentMessage, SentMessage>

SendMessageBatch

@JsonSerializable

data class SendMessageBatch(@Json(name = "QueueUrl") val queueUrl: Uri, @Json(name = "Entries") val entries: List<SendMessageBatchEntry>) : SQSAction<List<SendMessageBatchResultEntry>, SendMessageBatchResponse>

SendMessageBatchEntry

@JsonSerializable

data class SendMessageBatchEntry(val Id: String, val MessageBody: String, val DelaySeconds: Int?, val MessageAttributes: Map<String, MessageFieldsDto>?, val MessageDedeuplicationId: String?, val MessageGroupId: String?, val MessageSystemAttributes: Map<String, MessageFieldsDto>?)

SendMessageBatchResponse

@JsonSerializable

data class SendMessageBatchResponse(val Failed: List<BatchResultErrorEntry>?, val Successful: List<SendMessageBatchResultEntry>)

SendMessageBatchResultEntry

@JsonSerializable

data class SendMessageBatchResultEntry(val Id: String, val MD5OfMessageBody: String, val MessageId: SQSMessageId, val MD5OfMessageAttributes: String? = null, val SequenceNumber: String? = null)

SentMessage

@JsonSerializable

data class SentMessage(val MD5OfMessageBody: String, val MessageId: SQSMessageId, val MD5OfMessageAttributes: String? = null, val SequenceNumber: String? = null)

SentMessageBatchEntry

@JsonSerializable

data class SentMessageBatchEntry(val Id: String, val MessageId: SQSMessageId, val MD5OfMessageBody: String? = null, val MD5OfMessageAttributes: String? = null, val MD5OfMessageSystemAttributes: String? = null)