lib/amqp/channel.rb in amqp-1.1.4 vs lib/amqp/channel.rb in amqp-1.1.5

@@ -947,13 +947,15 @@
 
     # Closes AMQP channel.
     #
     # @api public
     def close(reply_code = 200, reply_text = DEFAULT_REPLY_TEXT, class_id = 0, method_id = 0, &block)
-      self.status = :closing
-      @connection.send_frame(AMQ::Protocol::Channel::Close.encode(@id, reply_code, reply_text, class_id, method_id))
+      self.once_open do
+        self.status = :closing
+        @connection.send_frame(AMQ::Protocol::Channel::Close.encode(@id, reply_code, reply_text, class_id, method_id))
 
-      self.redefine_callback :close, &block
+        self.redefine_callback :close, &block
+      end
     end
 
     # @endgroup