QueueConfig

class QueueConfig(val name: QueueName, val concurrency: Int = 8, val dispatcher: CoroutineDispatcher? = null)

Per-queue execution settings. Concurrency is a coroutine count, not a thread count: an I/O-bound queue can comfortably run hundreds. dispatcher overrides where handlers run; set it (for example to a bounded IO dispatcher) when handlers block, such as JDBC.

Constructors

Link copied to clipboard
constructor(name: QueueName, concurrency: Int = 8, dispatcher: CoroutineDispatcher? = null)

Properties

Link copied to clipboard
Link copied to clipboard
val dispatcher: CoroutineDispatcher?
Link copied to clipboard