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

RobustAMQPChannel

open class RobustAMQPChannel(val connection: RobustAMQPConnection, id: <Error class: unknown class>, frameMax: <Error class: unknown class>)

Constructors

RobustAMQPChannel

constructor(connection: RobustAMQPConnection, id: <Error class: unknown class>, frameMax: <Error class: unknown class>)

Properties

connection

open val connection: RobustAMQPConnection

Functions

basicAck

open suspend fun basicAck(deliveryTag: <Error class: unknown class>, multiple: Boolean)

basicCancel

open suspend fun basicCancel(consumerTag: String): <Error class: unknown class>

basicConsume

open suspend fun basicConsume(queue: String, consumerTag: String, noAck: Boolean, exclusive: Boolean, arguments: <Error class: unknown class>, onDelivery: suspend (<Error class: unknown class>) -> Unit, onCanceled: suspend (<Error class: unknown class>) -> Unit): <Error class: unknown class>

basicGet

open suspend fun basicGet(queue: String, noAck: Boolean): <Error class: unknown class>

basicNack

open suspend fun basicNack(deliveryTag: <Error class: unknown class>, multiple: Boolean, requeue: Boolean)

basicQos

open suspend fun basicQos(count: <Error class: unknown class>, global: Boolean): <Error class: unknown class>

basicReject

open suspend fun basicReject(deliveryTag: <Error class: unknown class>, requeue: Boolean)

cancelAll

open suspend fun cancelAll(channelClosed: <Error class: unknown class>)

confirmSelect

open suspend fun confirmSelect(): <Error class: unknown class>

exchangeBind

open suspend fun exchangeBind(destination: String, source: String, routingKey: String, arguments: <Error class: unknown class>): <Error class: unknown class>

exchangeDeclare

open suspend fun exchangeDeclare(name: String, type: String, durable: Boolean, autoDelete: Boolean, internal: Boolean, arguments: <Error class: unknown class>): <Error class: unknown class>

exchangeDelete

open suspend fun exchangeDelete(name: String, ifUnused: Boolean): <Error class: unknown class>

exchangeUnbind

open suspend fun exchangeUnbind(destination: String, source: String, routingKey: String, arguments: <Error class: unknown class>): <Error class: unknown class>

onBrokerClose

open fun onBrokerClose()

prepareForRestore

fun prepareForRestore()

prepareForWrite

open suspend fun prepareForWrite()

queueBind

open suspend fun queueBind(queue: String, exchange: String, routingKey: String, arguments: <Error class: unknown class>): <Error class: unknown class>

queueDeclare

open suspend fun queueDeclare(name: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, arguments: <Error class: unknown class>): <Error class: unknown class>

queueDelete

open suspend fun queueDelete(name: String, ifUnused: Boolean, ifEmpty: Boolean): <Error class: unknown class>

queueUnbind

open suspend fun queueUnbind(queue: String, exchange: String, routingKey: String, arguments: <Error class: unknown class>): <Error class: unknown class>

restore

suspend fun restore()

shouldRemoveOnBrokerClose

open fun shouldRemoveOnBrokerClose(): Boolean

Robust channels should not be removed from registry on broker close - they restore instead

txSelect

open suspend fun txSelect(): <Error class: unknown class>