lib/amq/client/async/channel.rb in amq-client-0.8.7.pre1 vs lib/amq/client/async/channel.rb in amq-client-0.8.7
- old
+ new
@@ -402,16 +402,18 @@
# @api plugin
# @private
def handle_close_ok(close_ok)
self.status = :closed
+ self.connection.clear_frames_on(self.id)
self.exec_callback_once_yielding_self(:close, close_ok)
end
# @api plugin
# @private
def handle_close(channel_close)
self.status = :closed
+ self.connection.clear_frames_on(self.id)
self.exec_callback_yielding_self(:error, channel_close)
self.handle_connection_interruption(channel_close)
end