amqp-client/dev.kourier.amqp.channel

Package-level declarations

Types

class AMQPChannels(var channelMax: UShort)

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

DefaultAMQPChannel

open class DefaultAMQPChannel(val connection: DefaultAMQPConnection, val id: ChannelId, val frameMax: UInt) : AMQPChannel

PartialDelivery

data class PartialDelivery(val method: Frame.Method.Basic)

Functions

basicGet

suspend fun AMQPChannel.basicGet(fetchedMessage: FetchedMessage): AMQPResponse.Channel.Message.Get

Get a single message using a FetchedMessage instance.

suspend fun AMQPChannel.basicGet(block: FetchedMessageBuilder.() -> Unit): AMQPResponse.Channel.Message.Get

Get a single message using a FetchedMessageBuilder block.

basicPublish

suspend fun AMQPChannel.basicPublish(publishedMessage: PublishedMessage): AMQPResponse.Channel.Basic.Published

Publish a ByteArray message using a PublishedMessage instance.

suspend fun AMQPChannel.basicPublish(block: PublishedMessageBuilder.() -> Unit): AMQPResponse.Channel.Basic.Published

Publish a ByteArray message using a PublishedMessageBuilder block.

basicQos

suspend fun AMQPChannel.basicQos(declaredQos: DeclaredQos): AMQPResponse.Channel.Basic.QosOk

Declares QoS settings using a DeclaredQos instance.

suspend fun AMQPChannel.basicQos(block: DeclaredQosBuilder.() -> Unit): AMQPResponse.Channel.Basic.QosOk

Declares QoS settings using a DeclaredQosBuilder block.

basicRecover

suspend fun AMQPChannel.basicRecover(recoveredMessages: RecoveredMessages): AMQPResponse.Channel.Basic.Recovered

Recover unacknowledged messages using a RecoveredMessages instance.

suspend fun AMQPChannel.basicRecover(block: RecoveredMessagesBuilder.() -> Unit): AMQPResponse.Channel.Basic.Recovered

Recover unacknowledged messages using a RecoveredMessagesBuilder block.

confirmSelect

suspend fun AMQPChannel.confirmSelect(selectedConfirmMode: SelectedConfirmMode): AMQPResponse.Channel.Confirm.Selected

Set channel in publish confirm mode using a SelectedConfirmMode instance.

suspend fun AMQPChannel.confirmSelect(block: SelectedConfirmModeBuilder.() -> Unit = {}): AMQPResponse.Channel.Confirm.Selected

Set channel in publish confirm mode using a SelectedConfirmModeBuilder block.

exchangeBind

suspend fun AMQPChannel.exchangeBind(boundExchange: BoundExchange): AMQPResponse.Channel.Exchange.Bound

Binds an exchange using a BoundExchange instance.

suspend fun AMQPChannel.exchangeBind(block: BoundExchangeBuilder.() -> Unit): AMQPResponse.Channel.Exchange.Bound

Binds an exchange using a BoundExchangeBuilder block.

exchangeDeclare

suspend fun AMQPChannel.exchangeDeclare(declaredExchange: DeclaredExchange): AMQPResponse.Channel.Exchange.Declared

Declares an exchange using a DeclaredExchange instance.

suspend fun AMQPChannel.exchangeDeclare(block: DeclaredExchangeBuilder.() -> Unit): AMQPResponse.Channel.Exchange.Declared

Declares an exchange using a DeclaredExchangeBuilder block.

exchangeDeclarePassive

suspend fun AMQPChannel.exchangeDeclarePassive(declaredPassiveExchange: DeclaredPassiveExchange): AMQPResponse.Channel.Exchange.Declared

Passively declares an exchange using a DeclaredPassiveExchange instance.

suspend fun AMQPChannel.exchangeDeclarePassive(block: DeclaredPassiveExchangeBuilder.() -> Unit): AMQPResponse.Channel.Exchange.Declared

Passively declares an exchange using a DeclaredPassiveExchangeBuilder block.

exchangeDelete

suspend fun AMQPChannel.exchangeDelete(deletedExchange: DeletedExchange): AMQPResponse.Channel.Exchange.Deleted

Deletes an exchange using a DeletedExchange instance.

suspend fun AMQPChannel.exchangeDelete(block: DeletedExchangeBuilder.() -> Unit): AMQPResponse.Channel.Exchange.Deleted

Deletes an exchange using a DeletedExchangeBuilder block.

exchangeUnbind

suspend fun AMQPChannel.exchangeUnbind(unboundExchange: UnboundExchange): AMQPResponse.Channel.Exchange.Unbound

Unbinds an exchange using a UnboundExchange instance.

suspend fun AMQPChannel.exchangeUnbind(block: UnboundExchangeBuilder.() -> Unit): AMQPResponse.Channel.Exchange.Unbound

Unbinds an exchange using a UnboundExchangeBuilder block.

flow

suspend fun AMQPChannel.flow(controlledFlow: ControlledFlow): AMQPResponse.Channel.Flowed

Send a flow message to broker using a ControlledFlow instance.

suspend fun AMQPChannel.flow(block: ControlledFlowBuilder.() -> Unit): AMQPResponse.Channel.Flowed

Send a flow message to broker using a ControlledFlowBuilder block.

queueBind

suspend fun AMQPChannel.queueBind(boundQueue: BoundQueue): AMQPResponse.Channel.Queue.Bound

Binds a queue using a BoundQueue instance.

suspend fun AMQPChannel.queueBind(block: BoundQueueBuilder.() -> Unit): AMQPResponse.Channel.Queue.Bound

Binds a queue using a BoundQueueBuilder block.

queueDeclare

suspend fun AMQPChannel.queueDeclare(declaredQueue: DeclaredQueue): AMQPResponse.Channel.Queue.Declared

Declares a queue using a DeclaredQueue instance.

suspend fun AMQPChannel.queueDeclare(block: DeclaredQueueBuilder.() -> Unit): AMQPResponse.Channel.Queue.Declared

Declares a queue using a DeclaredQueueBuilder block.

queueDeclarePassive

suspend fun AMQPChannel.queueDeclarePassive(declaredPassiveQueue: DeclaredPassiveQueue): AMQPResponse.Channel.Queue.Declared

Passively declares a queue using a DeclaredPassiveQueue instance.

suspend fun AMQPChannel.queueDeclarePassive(block: DeclaredPassiveQueueBuilder.() -> Unit): AMQPResponse.Channel.Queue.Declared

Passively declares a queue using a DeclaredPassiveQueueBuilder block.

queueDelete

suspend fun AMQPChannel.queueDelete(deletedQueue: DeletedQueue): AMQPResponse.Channel.Queue.Deleted

Deletes a queue using a DeletedQueue instance.

suspend fun AMQPChannel.queueDelete(block: DeletedQueueBuilder.() -> Unit): AMQPResponse.Channel.Queue.Deleted

Deletes a queue using a DeletedQueueBuilder block.

queuePurge

suspend fun AMQPChannel.queuePurge(purgedQueue: PurgedQueue): AMQPResponse.Channel.Queue.Purged

Purges a queue using a PurgedQueue instance.

suspend fun AMQPChannel.queuePurge(block: PurgedQueueBuilder.() -> Unit): AMQPResponse.Channel.Queue.Purged

Purges a queue using a PurgedQueueBuilder block.

queueUnbind

suspend fun AMQPChannel.queueUnbind(unboundQueue: UnboundQueue): AMQPResponse.Channel.Queue.Unbound

Unbinds a queue using a UnboundQueue instance.

suspend fun AMQPChannel.queueUnbind(block: UnboundQueueBuilder.() -> Unit): AMQPResponse.Channel.Queue.Unbound

Unbinds a queue using a UnboundQueueBuilder block.

txCommit

suspend fun AMQPChannel.txCommit(committedTransaction: CommittedTransaction): AMQPResponse.Channel.Tx.Committed

Commit a transaction using a CommittedTransaction instance.

suspend fun AMQPChannel.txCommit(block: CommittedTransactionBuilder.() -> Unit = {}): AMQPResponse.Channel.Tx.Committed

Commit a transaction using a CommittedTransactionBuilder block.

txRollback

suspend fun AMQPChannel.txRollback(rolledbackTransaction: RolledbackTransaction): AMQPResponse.Channel.Tx.Rollbacked

Rollback a transaction using a RolledbackTransaction instance.

suspend fun AMQPChannel.txRollback(block: RolledbackTransactionBuilder.() -> Unit = {}): AMQPResponse.Channel.Tx.Rollbacked

Rollback a transaction using a RolledbackTransactionBuilder block.

txSelect

suspend fun AMQPChannel.txSelect(selectedTransactionMode: SelectedTransactionMode): AMQPResponse.Channel.Tx.Selected

Set channel in transaction mode using a SelectedTransactionMode instance.

suspend fun AMQPChannel.txSelect(block: SelectedTransactionModeBuilder.() -> Unit = {}): AMQPResponse.Channel.Tx.Selected

Set channel in transaction mode using a SelectedTransactionModeBuilder block.