amqp-client-robust/dev.kourier.amqp.robust.states/ConsumedQueue/ConsumedQueue

ConsumedQueue

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