Azure / go-amqp

AMQP 1.0 client library for Go.
https://github.com/Azure/go-amqp
MIT License
104 stars 56 forks source link

Sending frames synchronizes with mux #279

Closed jhendrixMSFT closed 1 year ago

jhendrixMSFT commented 1 year ago

Session mux no longer consumes frames once the end performative has been sent. Instead, added channel endSent that links can select on. Added method link.txFrame for proper muxing of frames to session. Receivers send disposition frames through the mux to properly sync with the receiver being closed. Senders disable the outgoing transfers channel once close has started.

Fixes https://github.com/Azure/go-amqp/issues/278