connector-amqp/com.river.connector.amqp/ReceivingMessage/ManualAck

ManualAck

data class ManualAck(val consumerTag: String, val envelope: Envelope, val properties: AMQP.BasicProperties, val body: ByteArray, channel: Channel) : ReceivingMessage

Constructors

Link copied to clipboard
constructor(consumerTag: String, envelope: Envelope, properties: AMQP.BasicProperties, body: ByteArray, channel: Channel)

Properties

Link copied to clipboard
open override val body: ByteArray
Link copied to clipboard
open override val consumerTag: String
Link copied to clipboard
open override val envelope: Envelope
Link copied to clipboard
open override val properties: AMQP.BasicProperties

Functions

Link copied to clipboard
fun ack()
Link copied to clipboard
open fun bodyAsString(charset: Charset = Charset.defaultCharset()): String
Link copied to clipboard
fun nack(requeue: Boolean = true)