RestoreTimeoutException
class RestoreTimeoutException(val channelId: <Error class: unknown class>, val timeout: <Error class: unknown class>, cause: Throwable? = null) : IOException
Thrown when RobustAMQPChannel.restore exceeds the configured restore timeout.
Extends IOException (matching the rest of the AMQP exception hierarchy via AMQPException : IOException()) so user code that catches IOException around basicPublish(...) and similar calls catches this as well. kotlinx.io.IOException does NOT extend kotlinx.coroutines.CancellationException, so the recovery loop in RobustAMQPConnection.connectionFactory() still catches it via catch (e: Exception), logs it, and iterates rather than cancelling the recovery coroutine.
Constructors
Link copied to clipboard
constructor(channelId: <Error class: unknown class>, timeout: <Error class: unknown class>, cause: Throwable? = null)