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

Package-level declarations

Types

DeduplicationRecord

data class DeduplicationRecord(val messageId: SQSMessageId, val sequenceNumber: String?, val sentAt: Instant)

The checksums are not recorded here, because SQS digests the request it has just received even when it deduplicates that request away.

class FakeSQS(queues: Storage<List<SQSMessage>> = Storage.InMemory(), awsAccount: AwsAccount = AwsAccount.of("1234567890"), region: Region = Region.of("ldn-north-1"), deduplication: Storage<DeduplicationRecord> = Storage.InMemory(), queueConfig: Storage<QueueConfig> = Storage.InMemory(), clock: Clock = Clock.systemUTC()) : ChaoticHttpHandler

MessageMD5ChecksumInterceptor

object MessageMD5ChecksumInterceptor

From the AWS SDK

data class QueueConfig(val contentBasedDeduplication: Boolean = false)

The queue settings the fake honours. Recorded by CreateQueue, dropped by DeleteQueue.

Properties

DeduplicationInterval

val DeduplicationInterval: Duration

Functions

changeMessageVisibility

fun AwsRestJsonFake.changeMessageVisibility(queues: Storage<List<SQSMessage>>): RoutingHttpHandler

Received messages stay visible in the fake, so there is no timeout to change: only the queue is checked.

fun AwsRestJsonFake.createQueue(queues: Storage<List<SQSMessage>>, queueConfig: Storage<QueueConfig>, awsAccount: AwsAccount): RoutingHttpHandler

fun AwsRestJsonFake.deleteMessage(queues: Storage<List<SQSMessage>>): RoutingHttpHandler

deleteMessageBatch

fun AwsRestJsonFake.deleteMessageBatch(queues: Storage<List<SQSMessage>>): RoutingHttpHandler

fun AwsRestJsonFake.deleteQueue(queues: Storage<List<SQSMessage>>, deduplication: Storage<DeduplicationRecord> = Storage.InMemory(), queueConfig: Storage<QueueConfig> = Storage.InMemory()): RoutingHttpHandler

getQueueAttributes

fun AwsRestJsonFake.getQueueAttributes(queues: Storage<List<SQSMessage>>): RoutingHttpHandler

fun String.isFifoQueue(): Boolean

fun AwsRestJsonFake.listQueues(region: Region, account: AwsAccount, queues: Storage<List<SQSMessage>>): RoutingHttpHandler

fun main()

fun String.md5(): String

md5OfAttributes

fun SQSMessage.md5OfAttributes(): String

fun SQSMessage.md5OfBody(): String

fun Map<String, MessageFieldsDto>.md5OfFields(): String?

Null when the map is empty, because SQS omits the field rather than sending an empty digest.

fun AwsRestJsonFake.receiveMessage(queues: Storage<List<SQSMessage>>): RoutingHttpHandler

fun AwsRestJsonFake.sendMessage(queues: Storage<List<SQSMessage>>, deduplication: Storage<DeduplicationRecord> = Storage.InMemory(), queueConfig: Storage<QueueConfig> = Storage.InMemory(), clock: Clock = Clock.systemUTC(), sequenceNumbers: AtomicLong = AtomicLong()): RoutingHttpHandler

sendMessageBatch

fun AwsRestJsonFake.sendMessageBatch(queues: Storage<List<SQSMessage>>, deduplication: Storage<DeduplicationRecord> = Storage.InMemory(), queueConfig: Storage<QueueConfig> = Storage.InMemory(), clock: Clock = Clock.systemUTC(), sequenceNumbers: AtomicLong = AtomicLong()): RoutingHttpHandler