AMQPConnection

Properties

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

A flow of closed responses from the connection.

The configuration of the connection.

A deferred that completes when the connection is closed.

abstract val connectionOpened: Deferred<Unit>

A deferred that completes when the connection is opened.

A flow of opened responses from the connection.

The connection state.

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

Closes the connection.

abstract suspend fun openChannel(): AMQPChannel

Opens a new channel.

abstract suspend fun sendHeartbeat()

Sends a heartbeat frame.

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.