package com.jivimberg.sqs.published

import kotlinx.coroutines.delay
import kotlinx.coroutines.runBlocking
import software.amazon.awssdk.regions.Region
import software.amazon.awssdk.services.sqs.SqsClient
import software.amazon.awssdk.services.sqs.model.SendMessageRequest

fun main() = runBlocking {
    val sqs = SqsClient.builder()
            .region(Region.US_EAST_1)
            .build()

    var id = 0

    while (true) {
        id++

        val sendMsgRequest = SendMessageRequest.builder()
                .queueUrl(SQS_URL)
                .messageBody("hello world $id")
                .build()

        sqs.sendMessage(sendMsgRequest)
        println("Message sent with id: $id")
        delay((1000L..5000L).random())
    }
}