DefaultAMQPConnection

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

Constructors

constructor(config: AMQPConfig, messageListeningScope: CoroutineScope)

A flow of closed responses from the connection.

open override val config: AMQPConfig

The configuration of the connection.

A deferred that completes when the connection is closed.

A flow of opened responses from the connection.

The connection state.

Closes the connection.

open suspend override fun openChannel(): AMQPChannel

Opens a new channel.

open suspend override fun sendHeartbeat()

Sends a heartbeat frame.

open suspend override fun write(vararg frames: Frame)

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.

inline suspend fun <T : AMQPResponse> writeAndWaitForResponse(vararg frames: Frame): T