amqp-client/dev.kourier.amqp.states

Package-level declarations

Types

BoundExchange

data class BoundExchange(val destination: String, val source: String, val routingKey: String, val arguments: Table)

Bind an exchange to another exchange.

BoundExchangeBuilder

class BoundExchangeBuilder

Bind an exchange to another exchange.

BoundQueue

data class BoundQueue(val queue: String, val exchange: String, val routingKey: String, val arguments: Table)

Binds a queue to an exchange.

BoundQueueBuilder

class BoundQueueBuilder

Binds a queue to an exchange.

CommittedTransaction

class CommittedTransaction

Commit a transaction.

CommittedTransactionBuilder

class CommittedTransactionBuilder

Commit a transaction.

ConsumedQueue

data class ConsumedQueue(val queue: String, val consumerTag: String, val noAck: Boolean, val exclusive: Boolean, val arguments: Table, val onDelivery: suspend (AMQPResponse.Channel.Message.Delivery) -> Unit, val onCanceled: suspend (AMQPResponse.Channel) -> Unit)

ControlledFlow

data class ControlledFlow(val active: Boolean)

Send a flow message to broker to start or stop sending messages to consumers. Warning: Not supported by all brokers.

ControlledFlowBuilder

class ControlledFlowBuilder

Send a flow message to broker to start or stop sending messages to consumers. Warning: Not supported by all brokers.

DeclaredExchange

data class DeclaredExchange(val name: String, val type: String, val durable: Boolean, val autoDelete: Boolean, val internal: Boolean, val arguments: Table)

Declare an exchange.

DeclaredExchangeBuilder

class DeclaredExchangeBuilder

Declare an exchange.

DeclaredPassiveExchange

data class DeclaredPassiveExchange(val name: String)

Passively declares an exchange.

DeclaredPassiveExchangeBuilder

class DeclaredPassiveExchangeBuilder

Passively declares an exchange.

DeclaredPassiveQueue

data class DeclaredPassiveQueue(val name: String)

Passively declares a queue.

DeclaredPassiveQueueBuilder

class DeclaredPassiveQueueBuilder

Passively declares a queue.

DeclaredQos

data class DeclaredQos(val count: UShort, val global: Boolean)

Sets a prefetch limit when consuming messages. No more messages will be delivered to the consumer until one or more messages have been acknowledged or rejected.

DeclaredQosBuilder

class DeclaredQosBuilder

Sets a prefetch limit when consuming messages. No more messages will be delivered to the consumer until one or more messages have been acknowledged or rejected.

DeclaredQueue

data class DeclaredQueue(val name: String, val durable: Boolean, val exclusive: Boolean, val autoDelete: Boolean, val arguments: Table)

Declares a queue.

DeclaredQueueBuilder

class DeclaredQueueBuilder

Declares a queue.

DeletedExchange

data class DeletedExchange(val name: String, val ifUnused: Boolean)

Delete an exchange.

DeletedExchangeBuilder

class DeletedExchangeBuilder

Delete an exchange.

DeletedQueue

data class DeletedQueue(val name: String, val ifUnused: Boolean, val ifEmpty: Boolean)

Deletes a queue.

DeletedQueueBuilder

class DeletedQueueBuilder

Deletes a queue.

FetchedMessage

data class FetchedMessage(val queue: String, val noAck: Boolean)

Get a single message from a queue.

FetchedMessageBuilder

class FetchedMessageBuilder

Get a single message from a queue.

PublishedMessage

data class PublishedMessage(val body: ByteArray, val exchange: String, val routingKey: String, val mandatory: Boolean, val immediate: Boolean, val properties: Properties)

Publish a ByteArray message to exchange or queue.

PublishedMessageBuilder

class PublishedMessageBuilder

Publish a ByteArray message to exchange or queue.

PurgedQueue