klokka-ktor/com.eventslooped.klokka.ktor/KlokkaConfig/queue

queue

fun queue(name: QueueName, concurrency: Int = 8, dispatcher: CoroutineDispatcher? = null)

Declares a queue this process drains. Declaration order is drain priority: queues declared earlier are claimed first, mirroring KlokkaSettings.queues. If no queue is declared, the runtime falls back to a single queue named QueueName.DEFAULT.

fun queue(name: String, concurrency: Int = 8, dispatcher: CoroutineDispatcher? = null)

queue with the name as a plain string.