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

AMQPConnection

interface AMQPConnection

Inheritors

Properties

Link copied to clipboard
abstract val closedResponses: Flow<AMQPResponse.Connection.Closed>

A flow of closed responses from the connection.

Link copied to clipboard
abstract val config: AMQPConfig

The configuration of the connection.

Link copied to clipboard
abstract val connectionClosed: Deferred<AMQPException.ConnectionClosed>

A deferred that completes when the connection is closed.

Link copied to clipboard
abstract val openedResponses: Flow<AMQPResponse.Connection.Connected>

A flow of opened responses from the connection.

Link copied to clipboard
abstract val state: ConnectionState

The connection state.

Functions

Link copied to clipboard
abstract suspend fun close(reason: String = "", code: UShort): AMQPResponse.Connection.Closed

Closes the connection.

Link copied to clipboard
abstract suspend fun openChannel(): AMQPChannel

Opens a new channel.

Link copied to clipboard
abstract suspend fun sendHeartbeat()

Sends a heartbeat frame.

Link copied to clipboard
abstract suspend fun write(vararg frames: Frame)

Internal API to write raw frames to the connection.

abstract suspend fun write(bytes: ByteArray)

Internal API to write raw bytes to the connection.