0.2.2

amqp-client-robust/dev.kourier.amqp.robust/RobustAMQPConnection

RobustAMQPConnection

open class RobustAMQPConnection(config: AMQPConfig, messageListeningScope: CoroutineScope) : DefaultAMQPConnection

Constructors

RobustAMQPConnection

constructor(config: AMQPConfig, messageListeningScope: CoroutineScope)

Types

object Companion

Properties

val channels: AMQPChannels

closedResponses

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

open override val config: AMQPConfig

connectionClosed

open override val connectionClosed: CompletableDeferred<AMQPException.ConnectionClosed>

connectionResponses

val connectionResponses: MutableSharedFlow<AMQPResponse>

messageListeningScope

val messageListeningScope: CoroutineScope

openedResponses

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

open override var state: ConnectionState

Functions

open suspend override fun close(reason: String, code: UShort): AMQPResponse.Connection.Closed

open suspend override fun openChannel(): AMQPChannel

open suspend override fun sendHeartbeat()

open suspend override fun write(vararg frames: Frame)

open suspend override fun write(bytes: ByteArray)

writeAndWaitForResponse

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