lib/amq/client/async/channel.rb in amq-client-0.9.1 vs lib/amq/client/async/channel.rb in amq-client-0.9.2
- old
+ new
@@ -436,10 +436,10 @@
self.handle(Protocol::Channel::Close) do |connection, frame|
method = frame.decode_payload
channels = connection.channels
channel = channels[frame.channel]
-
+ connection.send_frame(Protocol::Channel::CloseOk.encode(frame.channel))
channel.handle_close(method)
end
self.handle(Protocol::Basic::QosOk) do |connection, frame|
channel = connection.channels[frame.channel]