amqp-client/dev.kourier.amqp.channel/AMQPChannels

AMQPChannels

class AMQPChannels(var channelMax: UShort)

Constructors

constructor(channelMax: UShort)

Properties

var channelMax: UShort

Functions

suspend fun add(channel: AMQPChannel)

suspend operator fun get(id: UShort): AMQPChannel?

suspend fun list(): List<AMQPChannel>

suspend fun remove(id: UShort)

suspend fun reserveNext(): UShort?