ConsumerQueueClient

Interface representing a consumer client for managing queue operations.

Functions

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

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

abstract suspend fun shutdown(): Boolean

Shuts down the queue client.