Package-level declarations
Types
Link copied to clipboard
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.
Link copied to clipboard
open class RobustAMQPChannel(val connection: RobustAMQPConnection, id: <Error class: unknown class>, frameMax: <Error class: unknown class>)
Link copied to clipboard
open class RobustAMQPConnection(config: <Error class: unknown class>, messageListeningScope: CoroutineScope)
Functions
Link copied to clipboard
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, config: <Error class: unknown class>): <Error class: unknown class>
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, block: <Error class: unknown class>.() -> Unit = {}): <Error class: unknown class>
Connect to broker, with automatic connection recovery.
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, url: <Error class: unknown class>, tls: <Error class: unknown class>? = null, sniServerName: String? = null, timeout: <Error class: unknown class> = AMQPConfig.Server.Defaults.timeout, connectionName: String = AMQPConfig.Server.Defaults.CONNECTION_NAME): <Error class: unknown class>
Connect to broker using a URL, with automatic connection recovery.
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, urlString: String, tls: <Error class: unknown class>? = null, sniServerName: String? = null, timeout: <Error class: unknown class> = AMQPConfig.Server.Defaults.timeout, connectionName: String = AMQPConfig.Server.Defaults.CONNECTION_NAME): <Error class: unknown class>
Connect to broker using a URL string, with automatic connection recovery.