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

AMQPReceiveChannel

class AMQPReceiveChannel(val consumeOk: AMQPResponse.Channel.Basic.ConsumeOk, val receiveChannel: ReceiveChannel<AMQPResponse.Channel.Message.Delivery>) : ReceiveChannel<AMQPResponse.Channel.Message.Delivery>

Constructors

Link copied to clipboard
constructor(consumeOk: AMQPResponse.Channel.Basic.ConsumeOk, receiveChannel: ReceiveChannel<AMQPResponse.Channel.Message.Delivery>)

Properties

Link copied to clipboard
Link copied to clipboard
open override val isClosedForReceive: Boolean
Link copied to clipboard
open override val isEmpty: Boolean
Link copied to clipboard
open override val onReceive: SelectClause1<AMQPResponse.Channel.Message.Delivery>
Link copied to clipboard
open override val onReceiveCatching: SelectClause1<ChannelResult<AMQPResponse.Channel.Message.Delivery>>
Link copied to clipboard
open override val onReceiveOrNull: SelectClause1<AMQPResponse.Channel.Message.Delivery?>
Link copied to clipboard

Functions

Link copied to clipboard
open override fun cancel(cause: CancellationException?)
Link copied to clipboard
open operator override fun iterator(): ChannelIterator<AMQPResponse.Channel.Message.Delivery>
Link copied to clipboard
Link copied to clipboard
open suspend override fun receive(): AMQPResponse.Channel.Message.Delivery
Link copied to clipboard
open suspend override fun receiveCatching(): ChannelResult<AMQPResponse.Channel.Message.Delivery>
Link copied to clipboard
Link copied to clipboard
open override fun tryReceive(): ChannelResult<AMQPResponse.Channel.Message.Delivery>