createAMQPConnection
suspend fun createAMQPConnection(coroutineScope: CoroutineScope, config: AMQPConfig): AMQPConnection
Connect to broker.
Return
AMQPConnection instance.
Parameters
coroutineScope
CoroutineScope on which to connect.
config
Configuration data.
suspend fun createAMQPConnection(coroutineScope: CoroutineScope, block: AMQPConfigBuilder.() -> Unit): AMQPConnection
Connect to broker.
Return
AMQPConnection instance.
Parameters
coroutineScope
CoroutineScope on which to connect.
block
The configuration block to apply to the AMQPConfigBuilder.
suspend fun createAMQPConnection(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.
Return
AMQPConnection instance.
Parameters
coroutineScope
CoroutineScope on which to connect.
url
The URL to create the configuration from.
tls
Optional TLS configuration.
sniServerName
Server name for TLS connection.
timeout
Optional connection timeout.
connectionName
Optional connection name.
suspend fun createAMQPConnection(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.
Return
AMQPConnection instance.
Parameters
coroutineScope
CoroutineScope on which to connect.
urlString
The URL string to create the configuration from.
tls
Optional TLS configuration.
sniServerName
Server name for TLS connection.
timeout
Optional connection timeout.
connectionName
Optional connection name.