amqp-client-robust/dev.kourier.amqp.robust/createRobustAMQPConnection

createRobustAMQPConnection

suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, config: AMQPConfig): AMQPConnection

Connect to broker, with automatic connection recovery.

Return

AMQPConnection instance.

Parameters

coroutineScope

CoroutineScope on which to connect.

config

Configuration data.

suspend fun createRobustAMQPConnection(coroutineScope: CoroutineScope, block: AMQPConfigBuilder.() -> Unit): AMQPConnection

Connect to broker, with automatic connection recovery.

Return

AMQPConnection instance.

Parameters

coroutineScope

CoroutineScope on which to connect.

block

The configuration block to apply to the AMQPConfigBuilder.

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.

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 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.

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.