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]