RobustAMQPConnection

open class RobustAMQPConnection(config: <Error class: unknown class>, messageListeningScope: CoroutineScope)

Constructors

constructor(config: <Error class: unknown class>, messageListeningScope: CoroutineScope)

open suspend fun close(reason: String, code: <Error class: unknown class>): <Error class: unknown class>

open suspend fun closeFromBroker(payload: <Error class: unknown class>)

open suspend fun connect()

open fun createChannel(id: <Error class: unknown class>, frameMax: <Error class: unknown class>): <Error class: unknown class>