core/karya.core.queues/ProducerQueueClient

ProducerQueueClient

interface ProducerQueueClient

Interface representing a producer client for managing queue operations.

Functions

Link copied to clipboard
abstract suspend fun initialize()

Initializes the queue producer client.

Link copied to clipboard
abstract suspend fun push(message: QueueMessage, queueType: QueueType = EXECUTOR)

Pushes a message to the specified queue.

Link copied to clipboard
abstract suspend fun shutdown(): Boolean

Shuts down the queue client.