amqp-core/dev.kourier.amqp

Package-level declarations

Types

BuiltinExchangeType

object BuiltinExchangeType

ChannelId

typealias ChannelId = UShort

Field

sealed class Field

Frame

@Serializable(with = FrameSerializer::class)

data class Frame(val channelId: ChannelId, val payload: Frame.Payload)

InternalAmqpApi

annotation class InternalAmqpApi

Properties

@Serializable(with = PropertiesSerializer::class)

data class Properties(val contentType: String? = null, val contentEncoding: String? = null, val headers: Table? = null, val deliveryMode: UByte? = null, val priority: UByte? = null, val correlationId: String? = null, val replyTo: String? = null, val expiration: String? = null, val messageId: String? = null, val timestamp: Long? = null, val type: String? = null, val userId: String? = null, val appId: String? = null, val reserved1: String? = null)

PropertiesBuilder

class PropertiesBuilder

Protocol

object Protocol

ProtocolError

sealed class ProtocolError : Exception

Table

typealias Table = Map<String, Field>