data-rabbitmq/karya.data.rabbitmq/RabbitMqQueueClient

RabbitMqQueueClient

class RabbitMqQueueClient @Inject constructor(json: Json, channel: Channel, connection: Connection, consumer: RabbitMqConsumer, initializeConfiguration: InitializeConfiguration) : ProducerQueueClient, ConsumerQueueClient

Constructors

RabbitMqQueueClient

@Inject

constructor(json: Json, channel: Channel, connection: Connection, consumer: RabbitMqConsumer, initializeConfiguration: InitializeConfiguration)

Types

object Companion : Logging

Functions

open suspend override fun consume(onMessage: suspend (QueueMessage) -> Unit)

open suspend override fun initialize()

open suspend override fun push(message: QueueMessage, queueType: QueueType)

open suspend override fun shutdown(): Boolean