Package-level declarations
Types
Link copied to clipboard
open class RobustAMQPChannel(val connection: RobustAMQPConnection, id: ChannelId, frameMax: UInt) : DefaultAMQPChannel
Link copied to clipboard
open class RobustAMQPConnection(config: AMQPConfig, messageListeningScope: CoroutineScope) : DefaultAMQPConnection
Functions
Link copied to clipboard
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, config: AMQPConfig): AMQPConnection
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, block: AMQPConfigBuilder.() -> Unit): AMQPConnection
Connect to broker, with automatic connection recovery.
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, url: Url, tls: TLSConfig? = null, sniServerName: String? = null, timeout: Duration = AMQPConfig.Server.Defaults.timeout, connectionName: String = AMQPConfig.Server.Defaults.CONNECTION_NAME): AMQPConnection
Connect to broker using a URL, with automatic connection recovery.
suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, urlString: String, tls: TLSConfig? = null, sniServerName: String? = null, timeout: Duration = AMQPConfig.Server.Defaults.timeout, connectionName: String = AMQPConfig.Server.Defaults.CONNECTION_NAME): AMQPConnection
Connect to broker using a URL string, with automatic connection recovery.