amqp-client/dev.kourier.amqp.connection

Package-level declarations

Types

Link copied to clipboard
data class AMQPConfig(val connection: AMQPConfig.Connection, val server: AMQPConfig.Server)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
interface AMQPConnection
Link copied to clipboard
Link copied to clipboard
open class DefaultAMQPConnection(val config: AMQPConfig, val messageListeningScope: CoroutineScope) : AMQPConnection
Link copied to clipboard
object FrameDecoder
Link copied to clipboard

Functions

Link copied to clipboard
fun amqpConfig(block: AMQPConfigBuilder.() -> Unit): AMQPConfig

Creates an AMQPConfig using a DSL builder.

fun amqpConfig(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): AMQPConfig

Convenience function to create AMQPConfig from a URL and key options.

fun amqpConfig(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): AMQPConfig

Convenience function to create AMQPConfig from a URL string and key options.

Link copied to clipboard
suspend fun createAMQPConnection(coroutineScope: CoroutineScope, config: AMQPConfig): AMQPConnection
suspend fun createAMQPConnection(coroutineScope: CoroutineScope, block: AMQPConfigBuilder.() -> Unit = {}): AMQPConnection

Connect to broker.

suspend fun createAMQPConnection(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): AMQPConnection

Connect to broker using a URL.

suspend fun createAMQPConnection(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): AMQPConnection

Connect to broker using a URL string.