usagi/dimensional.usagi.channel.method

Package-level declarations

Types

value class AccessMethods(val channel: Channel)

value class BasicMethods(val channel: Channel)

value class ChannelMethods(val channel: Channel)

value class ConfirmMethods(val channel: Channel)

ExchangeMethods

value class ExchangeMethods(val channel: Channel)

PublicationBuilder

class PublicationBuilder

value class QueueMethods(val channel: Channel)

value class TxMethods(val channel: Channel)

Functions

suspend fun BasicMethods.consume(method: AMQP.Basic.Consume): Consumer

suspend fun BasicMethods.consume(block: AMQP.Basic.Consume.Builder.() -> Unit): Consumer

suspend fun BasicMethods.publish(block: PublicationBuilder.() -> Unit)

Publish a message

Properties

val Channel.access: AccessMethods

val Channel.basic: BasicMethods

val Channel.channel: ChannelMethods

val Channel.confirm: ConfirmMethods

val Channel.exchange: ExchangeMethods

val Channel.queue: QueueMethods

val Channel.tx: TxMethods