amqp-client/dev.kourier.amqp.connection/DefaultAMQPConnection/connectionClosed

connectionClosed

open override val connectionClosed: CompletableDeferred<AMQPException.ConnectionClosed>

A deferred that completes when the connection is closed.