core/karya.core.queues/ConsumerQueueClient/consume

consume

abstract suspend fun consume(onMessage: suspend (QueueMessage) -> Unit)

Consumes messages from the queue and processes them using the provided handler.

Parameters

onMessage

The handler function to process each consumed message.