data class ChannelClosed(val replyCode: <Error class: unknown class>? = null, val replyText: String? = null, val isInitiatedByApplication: Boolean = false) : AMQPException

ChannelNotInConfirmMode

data object ChannelNotInConfirmMode : AMQPException

ConnectionBlocked

data object ConnectionBlocked : AMQPException

ConnectionClose

data class ConnectionClose(val broker: Throwable? = null, val connection: Throwable? = null) : AMQPException

ConnectionClosed

data class ConnectionClosed(val replyCode: <Error class: unknown class>? = null, val replyText: String? = null, val isInitiatedByApplication: Boolean = false) : AMQPException

ConsumerAlreadyCancelled

data object ConsumerAlreadyCancelled : AMQPException

ConsumerCancelled

data object ConsumerCancelled : AMQPException

InvalidMessage

data object InvalidMessage : AMQPException

InvalidResponse

data class InvalidResponse(val response: AMQPResponse) : AMQPException

InvalidUrl

data object InvalidUrl : AMQPException

InvalidUrlScheme

data object InvalidUrlScheme : AMQPException

RpcTimeout

data class RpcTimeout(val channelId: <Error class: unknown class>, val timeout: <Error class: unknown class>) : AMQPException

A channel-level RPC (queueDeclare, basicGet, confirmSelect, …) did not receive a response within the configured rpcTimeout. Prevents a stalled/black-holed broker from suspending the caller forever. Not a kotlinx.coroutines.CancellationException, so robust recovery treats it as a normal failure.

TooManyOpenedChannels

data object TooManyOpenedChannels : AMQPException