amqp-client/dev.kourier.amqp.connection/DefaultAMQPConnection

DefaultAMQPConnection

open class DefaultAMQPConnection(val config: AMQPConfig, val messageListeningScope: CoroutineScope) : AMQPConnection

Constructors

constructor(config: AMQPConfig, messageListeningScope: CoroutineScope)

Types

Companion

object Companion

Properties

blockedResponses

open override val blockedResponses: Flow<AMQPResponse.Connection.Blocked>

A flow of blocked responses from the connection. Emitted when the broker signals the connection is resource-constrained.

channels

val channels: AMQPChannels

closedResponses

open override val closedResponses: Flow<AMQPResponse.Connection.Closed>

A flow of closed responses from the connection.

config

open override val config: AMQPConfig

The configuration of the connection.

connectionClosed

open override val connectionClosed: CompletableDeferred<AMQPException.ConnectionClosed>

A deferred that completes when the connection is closed.

connectionOpened

open override var connectionOpened: CompletableDeferred<Unit>

A deferred that completes when the connection is opened.

connectionResponses

val connectionResponses: MutableSharedFlow<AMQPResponse>

messageListeningScope

val messageListeningScope: CoroutineScope

openedResponses

open override val openedResponses: Flow<AMQPResponse.Connection.Connected>

A flow of opened responses from the connection.

state

open override var state: ConnectionState

The connection state.

unblockedResponses

open override val unblockedResponses: Flow<AMQPResponse.Connection.Unblocked>

A flow of unblocked responses from the connection. Emitted when the broker signals the connection is no longer resource-constrained.

writeBlocked

val writeBlocked: MutableStateFlow<Boolean>

Functions

open suspend override fun close(reason: String, code: <Error class: unknown class>): AMQPResponse.Connection.Closed

Closes the connection.

openChannel

open suspend override fun openChannel(): AMQPChannel

Opens a new channel.

sendHeartbeat

open suspend override fun sendHeartbeat()

Sends a heartbeat frame.

write

open suspend override fun write(vararg frames: <Error class: unknown class>)

Internal API to write raw frames to the connection.

open suspend override fun write(bytes: ByteArray)

Internal API to write raw bytes to the connection.

writeAndWaitForResponse

inline suspend fun <T : AMQPResponse> writeAndWaitForResponse(vararg frames: <Error class: unknown class>): T