Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Change order of operations in shutdown

  • Loading branch information...
commit 103cdb1f4b710c7802eac48e59cb37a68420cc77 1 parent b63b4c8
Gavin M. Roy authored
Showing with 2 additions and 2 deletions.
  1. +2 −2 pika/connection.py
View
4 pika/connection.py
@@ -745,10 +745,10 @@ def _on_connection_closed(self, method_frame, from_adapter=False):
LOGGER.warning("Disconnected from RabbitMQ at %s:%i (%s): %s",
self.params.host, self.params.port,
self.closing[0], self.closing[1])
- self._set_connection_state(self.CONNECTION_CLOSED)
- self._remove_connection_callbacks()
if not from_adapter:
self._adapter_disconnect()
+ self._set_connection_state(self.CONNECTION_CLOSED)
+ self._remove_connection_callbacks()
for channel in self._channels:
self._channels[channel].on_remote_close(method_frame)
self._process_connection_closed_callbacks()
Please sign in to comment.
Something went wrong with that request. Please try again.