messaging-amqp/dev.kaccelero.commons.messaging/IMessagingService

IMessagingService

interface IMessagingService

Inheritors

Properties

Link copied to clipboard
abstract val channel: AMQPChannel?
Link copied to clipboard
abstract val connection: AMQPConnection?

Functions

Link copied to clipboard
abstract suspend fun connect()
Link copied to clipboard
abstract suspend fun exchangeDeclare(exchange: IMessagingExchange, type: String = BuiltinExchangeType.DIRECT, arguments: Map<String, Field> = mapOf())
Link copied to clipboard
abstract suspend fun listen()
Link copied to clipboard
abstract suspend fun queueBind(queue: IMessagingQueue, exchange: IMessagingExchange, routingKey: IMessagingKey, arguments: Map<String, Field> = mapOf())
Link copied to clipboard
abstract suspend fun queueDeclare(queue: IMessagingQueue, exchange: IMessagingExchange? = null, durable: Boolean = true, exclusive: Boolean = false, autoDelete: Boolean = false, arguments: Map<String, Field> = mapOf())
Link copied to clipboard
abstract suspend fun setup()