amqp-client-robust/dev.kourier.amqp.robust/RobustAMQPChannel

RobustAMQPChannel

open class RobustAMQPChannel(val connection: RobustAMQPConnection, id: ChannelId, frameMax: UInt) : DefaultAMQPChannel

Constructors

RobustAMQPChannel

constructor(connection: RobustAMQPConnection, id: ChannelId, frameMax: UInt)

Properties

channelClosed

open override val channelClosed: CompletableDeferred<AMQPException.ChannelClosed>

channelResponses

val channelResponses: MutableSharedFlow<AMQPResponse>

closedResponses

open override val closedResponses: Flow<AMQPResponse.Channel.Closed>

connection

open override val connection: RobustAMQPConnection

flowResponses

open override val flowResponses: Flow<AMQPResponse.Channel.Flowed>

frameMax

val frameMax: UInt

open override val id: ChannelId

isConfirmMode

open override var isConfirmMode: Boolean

isTxMode

open override var isTxMode: Boolean

nextMessage

var nextMessage: PartialDelivery?

openedResponses

open override val openedResponses: Flow<AMQPResponse.Channel.Opened>

publishConfirmResponses

open override val publishConfirmResponses: Flow<AMQPResponse.Channel.Basic.PublishConfirm>

returnResponses

open override val returnResponses: Flow<AMQPResponse.Channel.Message.Return>

state

open override var state: ConnectionState

writeMutex

val writeMutex: Mutex

Functions

basicAck

open suspend override fun basicAck(message: AMQPMessage, multiple: Boolean)

open suspend override fun basicAck(deliveryTag: ULong, multiple: Boolean)

basicCancel

open suspend override fun basicCancel(consumerTag: String): AMQPResponse.Channel.Basic.Canceled

basicConsume

open suspend override fun basicConsume(queue: String, consumerTag: String, noAck: Boolean, exclusive: Boolean, arguments: Table): AMQPReceiveChannel

open suspend override fun basicConsume(queue: String, consumerTag: String, noAck: Boolean, exclusive: Boolean, arguments: Table, onDelivery: suspend (AMQPResponse.Channel.Message.Delivery) -> Unit, onCanceled: suspend (AMQPResponse.Channel) -> Unit): AMQPResponse.Channel.Basic.ConsumeOk

basicGet

open suspend override fun basicGet(queue: String, noAck: Boolean): AMQPResponse.Channel.Message.Get

basicNack

open suspend override fun basicNack(message: AMQPMessage, multiple: Boolean, requeue: Boolean)

open suspend override fun basicNack(deliveryTag: ULong, multiple: Boolean, requeue: Boolean)

basicPublish

open suspend override fun basicPublish(body: ByteArray, exchange: String, routingKey: String, mandatory: Boolean, immediate: Boolean, properties: Properties): AMQPResponse.Channel.Basic.Published

basicQos

open suspend override fun basicQos(count: UShort, global: Boolean): AMQPResponse.Channel.Basic.QosOk

basicRecover

open suspend override fun basicRecover(requeue: Boolean): AMQPResponse.Channel.Basic.Recovered

basicReject

open suspend override fun basicReject(message: AMQPMessage, requeue: Boolean)

open suspend override fun basicReject(deliveryTag: ULong, requeue: Boolean)

cancelAll

open suspend override fun cancelAll(channelClosed: AMQPException.ChannelClosed)

open suspend override fun close(reason: String, code: UShort): AMQPResponse.Channel.Closed

confirmSelect

open suspend override fun confirmSelect(): AMQPResponse.Channel.Confirm.Selected

consumerCount

open suspend override fun consumerCount(name: String): UInt

exchangeBind

open suspend override fun exchangeBind(destination: String, source: String, routingKey: String, arguments: Table): AMQPResponse.Channel.Exchange.Bound

exchangeDeclare

open suspend override fun exchangeDeclare(name: String, type: String, durable: Boolean, autoDelete: Boolean, internal: Boolean, arguments: Table): AMQPResponse.Channel.Exchange.Declared

exchangeDeclarePassive

open suspend override fun exchangeDeclarePassive(name: String): AMQPResponse.Channel.Exchange.Declared

exchangeDelete

open suspend override fun exchangeDelete(name: String, ifUnused: Boolean): AMQPResponse.Channel.Exchange.Deleted

exchangeUnbind

open suspend override fun exchangeUnbind(destination: String, source: String, routingKey: String, arguments: Table): AMQPResponse.Channel.Exchange.Unbound

flow

open suspend override fun flow(active: Boolean): AMQPResponse.Channel.Flowed

messageCount

open suspend override fun messageCount(name: String): UInt

open

open suspend override fun open(): AMQPResponse.Channel.Opened

queueBind

open suspend override fun queueBind(queue: String, exchange: String, routingKey: String, arguments: Table): AMQPResponse.Channel.Queue.Bound

queueDeclare

open suspend override fun queueDeclare(): AMQPResponse.Channel.Queue.Declared

open suspend override fun queueDeclare(name: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, arguments: Table): AMQPResponse.Channel.Queue.Declared

queueDeclarePassive

open suspend override fun queueDeclarePassive(name: String): AMQPResponse.Channel.Queue.Declared

queueDelete

open suspend override fun queueDelete(name: String, ifUnused: Boolean, ifEmpty: Boolean): AMQPResponse.Channel.Queue.Deleted

queuePurge

open suspend override fun queuePurge(name: String): AMQPResponse.Channel.Queue.Purged

queueUnbind

open suspend override fun queueUnbind(queue: String, exchange: String, routingKey: String, arguments: Table): AMQPResponse.Channel.Queue.Unbound

restore

suspend fun restore()

txCommit

open suspend override fun txCommit(): AMQPResponse.Channel.Tx.Committed

txRollback

open suspend override fun txRollback(): AMQPResponse.Channel.Tx.Rollbacked

txSelect

open suspend override fun txSelect(): AMQPResponse.Channel.Tx.Selected

write

open suspend override fun write(vararg frames: Frame)

writeAndWaitForResponse

inline suspend fun <T : AMQPResponse> writeAndWaitForResponse(vararg frames: Frame): T