connectionResponses

val connectionResponses: MutableSharedFlow<AMQPResponse>