data-sqs/karya.data.sqs/SqsQueueClient

SqsQueueClient

class SqsQueueClient @Inject constructor(json: Json, sqsClient: SqsClient, config: QueueConfig, consumeMessage: ConsumeMessage, checkIfQueueCreated: CheckIfQueueCreated) : ProducerQueueClient, ConsumerQueueClient

Constructors

@Inject

constructor(json: Json, sqsClient: SqsClient, config: QueueConfig, consumeMessage: ConsumeMessage, checkIfQueueCreated: CheckIfQueueCreated)

Types

object Companion : Logging

Functions

open suspend override fun consume(onMessage: suspend (QueueMessage) -> Unit)

open suspend override fun initialize()

open suspend override fun push(message: QueueMessage, queueType: QueueType)

open suspend override fun shutdown(): Boolean