amqp-client/dev.kourier.amqp/AMQPException/RpcTimeout

RpcTimeout

data class RpcTimeout(val channelId: ChannelId, val timeout: Duration) : 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.

Constructors

RpcTimeout

constructor(channelId: ChannelId, timeout: Duration)

Properties

cause

expect open val cause: Throwable?

channelId

val channelId: ChannelId

message

open override val message: String

timeout

val timeout: Duration