lib/amqp/channel.rb in amqp-0.8.0.rc4 vs lib/amqp/channel.rb in amqp-0.8.0.rc5
- old
+ new
@@ -851,13 +851,13 @@
# Overrides AMQ::Client::Channel version to also call global callback
# (if defined) for backwards compatibility.
#
# @private
# @api private
- def handle_close(_, exception = nil)
- super(_, exception)
+ def handle_close(method)
+ super(method)
- self.class.error(exception.message)
+ self.class.error(method.reply_text)
end
# Resets channel state (for example, list of registered queue objects and so on).
#