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

Package-level declarations

Types

@JsonSerializable

data class ChangeMessageVisibility(@Json(name = "QueueUrl") val queueUrl: Uri, @Json(name = "ReceiptHandle") val receiptHandle: ReceiptHandle, @Json(name = "VisibilityTimeout") val visibilityTimeout: Int, val expires: ZonedDateTime? = null) : SQSAction<Unit, Unit> , Action<Result<Unit, RemoteFailure>>

A visibilityTimeout of 0 returns the message to the queue immediately.

ChangeMessageVisibilityData

@JsonSerializable

data class ChangeMessageVisibilityData(val QueueUrl: Uri, val ReceiptHandle: ReceiptHandle, val VisibilityTimeout: Int)

CreatedQueue

@JsonSerializable

data class CreatedQueue(val QueueUrl: Uri)

CreateQueue

@JsonSerializable

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

DeleteMessage

@JsonSerializable

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

DeleteMessageBatch

@JsonSerializable

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

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> , Action<Result4k<Unit, RemoteFailure>>

GetQueueAttributes

@JsonSerializable

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

ListQueues

@JsonSerializable

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

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, @Json(name = "MessageSystemAttributeNames") val messageSystemAttributeNames: List<String>? = null) : SQSAction<List<SQSMessage>, ReceiveMessageResponse> , Action<Result4k<List<SQSMessage>, RemoteFailure>>

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> , Action<Result4k<SentMessage, RemoteFailure>>

SendMessageBatch

@JsonSerializable

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

SendMessageBatchEntry

@JsonSerializable

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

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, val MD5OfMessageSystemAttributes: String? = null)

SentMessage

@JsonSerializable

data class SentMessage(val MD5OfMessageBody: String, val MessageId: SQSMessageId, val MD5OfMessageAttributes: String? = null, val SequenceNumber: String? = null, val MD5OfMessageSystemAttributes: 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)