Only close the dispatcher if it hasn't already been closed. closes pi…

…ka#5
Pankrat · May 17, 2010 · 20d3307 · 20d3307
1 parent 3d5c081
commit 20d3307
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pika/asyncore_adapter.py b/pika/asyncore_adapter.py
@@ -103,7 +103,8 @@ def connect(self, host, port):
         self.dispatcher.connect((host, port or spec.PORT))
 
     def disconnect_transport(self):
-        self.dispatcher.close()
+        if self.dispatcher:
+            self.dispatcher.close()
 
     def drain_events(self):
         loop(count = 1)