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

ReceivingMessage

@ExperimentalCoroutinesApi
interface ReceivingMessage

Inheritors

Types

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

Properties

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

Functions

Link copied to clipboard
open fun bodyAsString(charset: Charset = Charset.defaultCharset()): String