rabbitmq / rabbitmq-amqp1.0

AMQP 1.0 support for RabbitMQ
https://www.rabbitmq.com/
Other
93 stars 20 forks source link

Ensure session has time to finish processing on connection shutdown. #53

Closed kjnilsson closed 7 years ago

kjnilsson commented 7 years ago

When an amqp 1.0 connection is closed very shortly after sending a large batch of frames it is possible that the supervision tree terminates before the session process has had time to process them all. This change exposes a call function on the session that is called upon the reader receiving an v1_0.close{} frame. This ensure the active sessions get at least 5 seconds to empty their internal message buffers.