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

Package-level declarations

Types

@JsonSerializable

data class BatchResultErrorEntry(val Code: String, val Id: String, val SenderFault: Boolean, val Message: String? = null)

MessageAttribute

interface MessageAttribute : MessageFields

MessageSystemAttribute

interface MessageSystemAttribute : MessageFields

MessageSystemAttributeName

object MessageSystemAttributeName

Selectable via ReceiveMessage's MessageSystemAttributeNames. All is a wildcard, not an attribute.

QueueName

class QueueName : ResourceId

ReceiptHandle

class ReceiptHandle : AbstractValue<String>

SQSMessage

@JsonSerializable

data class SQSMessage(@Json(name = "MessageId") val messageId: SQSMessageId, @Json(name = "Body") val body: String, @Json(name = "MD5OfBody") val md5OfBody: String, @Json(name = "ReceiptHandle") val receiptHandle: ReceiptHandle, @Json(name = "MessageAttributes") val messageAttributes: Map<String, MessageFieldsDto> = emptyMap(), @Json(name = "Attributes") val systemAttributes: Map<String, String> = emptyMap())

SQSMessageAttribute

sealed class SQSMessageAttribute : MessageFields

SQSMessageId

class SQSMessageId : AbstractValue<String>

Functions

MessageAttribute

@JvmName(name = "MessageAttributeBinaryList")

fun MessageAttribute(name: String, value: List<Base64Blob>): MessageAttribute

fun MessageAttribute(name: String, value: Base64Blob): MessageAttribute

fun MessageAttribute(name: String, value: String, dataType: DataType): MessageAttribute

@JvmName(name = "MessageAttributeStringList")

fun MessageAttribute(name: String, value: List<String>, dataType: DataType): MessageAttribute

MessageSystemAttribute

fun MessageSystemAttribute(name: String, value: String, dataType: DataType): MessageSystemAttribute

toSqs

fun MessageFieldsDto.toSqs(name: String): MessageAttribute