usagi/dimensional.usagi.connection

Package-level declarations

Types

ClientProperties

class ClientProperties

class Connection(socket: Socket, resources: ConnectionResources)

ConnectionCancelledException

class ConnectionCancelledException(reason: AMQP.Connection.Close, val cause: Throwable? = null, val manual: Boolean) : CancellationException

ConnectionPreferences

data class ConnectionPreferences(val maxChannelCount: Int = DEFAULT_MAX_CHANNEL_COUNT, val maxFrameSize: Int = 0, val heartbeat: Int = 60)

Preferences for an Connection

ConnectionPreferencesBuilder

class ConnectionPreferencesBuilder

ConnectionResources

data class ConnectionResources(val scope: CoroutineScope = CoroutineScope(Dispatchers.Default + Job()), val protocol: Protocol, val handshakeTimeout: Duration, val authMechanisms: List<AuthMechanism>, val preferences: ConnectionPreferences, val clientProperties: Map<String, Any?>, val eventFlow: MutableSharedFlow<ConnectionEvent>)

ConnectionResourcesBuilder

class ConnectionResourcesBuilder

HeartbeatDispatcher

class HeartbeatDispatcher(val connection: Connection, kyuso: Kyuso)