Merge pull request #537 from vitaly-krugl/fix-closing-args

Fix #535, allowing the expected `reply_code` and `reply_text` to be passed to `on_close_callback`

pika/connection.py

@@ -1188,6 +1188,9 @@ def _on_connection_closed(self, method_frame, from_adapter=False):
             self.closing = (method_frame.method.reply_code,
                             method_frame.method.reply_text)
 
+        # Save the codes because self.closing gets reset by _adapter_disconnect
+        reply_code, reply_text = self.closing
+
         # Stop the heartbeat checker if it exists
         if self.heartbeat:
             self.heartbeat.stop()
@@ -1197,7 +1200,7 @@ def _on_connection_closed(self, method_frame, from_adapter=False):
             self._adapter_disconnect()
 
         # Invoke a method frame neutral close
-        self._on_disconnect(self.closing[0], self.closing[1])
+        self._on_disconnect(reply_code, reply_text)
 
     def _on_connection_error(self, connection_unused, error_message=None):
         """Default behavior when the connecting connection can not connect.