Fixed bug mentioned in Issue #357

pika · Jun 6, 2013 · dfbba50 · dfbba50
1 parent 4c663ac
commit dfbba50
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pika/adapters/blocking_connection.py b/pika/adapters/blocking_connection.py
@@ -197,7 +197,8 @@ def close(self, reply_code=200, reply_text='Normal shutdown'):
             self._close_channels(reply_code, reply_text)
         while self._has_open_channels:
             self.process_data_events()
-        self._send_connection_close(reply_code, reply_text)
+        if self.socket:
+            self._send_connection_close(reply_code, reply_text)
         while self.is_closing:
             self.process_data_events()
         if self.heartbeat: