Fix for Transport.__del__ for late threads at shutdown. Closes #36

1 files changed, 7 insertions, 3 deletions

diff --git a/amqp/transport.py b/amqp/transport.py
index 8acdd4a..30ecd3e 100644
--- a/amqp/transport.py
+++ b/amqp/transport.py
@@ -109,9 +109,13 @@ class _AbstractTransport(object):
 
     def __del__(self):
         try:
-            self.close()
-        except socket.error:
-            pass
+            # socket module may have been collected by gc
+            # if this is called by a thread at shutdown.
+            if socket is not None:
+                try:
+                    self.close()
+                except socket.error:
+                    pass
         finally:
             self.sock = None