data-sqs/karya.data.sqs.usecases/ConsumeMessage

ConsumeMessage

class ConsumeMessage @Inject constructor(json: Json, sqsClient: SqsClient, config: QueueConfig)

Constructors

Link copied to clipboard
@Inject
constructor(json: Json, sqsClient: SqsClient, config: QueueConfig)

Types

Link copied to clipboard
object Companion : Logging

Functions

Link copied to clipboard
suspend fun invoke(queueUrl: String, onMessage: suspend (QueueMessage) -> Unit)