huntin' and loggin'

coolamqp/clustering/cluster.py

@@ -147,7 +147,7 @@ class Cluster(object):
         """
         logger.info('Commencing shutdown')
 
-        self.snr.shutdown()
+#        self.snr.shutdown()
         self.listener.terminate()
         if wait:
             self.listener.join()

coolamqp/uplink/listener/epoll_listener.py

@@ -113,7 +113,7 @@ class EpollListener(object):
         This object is unusable after this call.
         """
         self.time_events = []
-        for sock in six.itervalues(self.fd_to_sock):
+        for sock in list(six.itervalues(self.fd_to_sock)):
             sock.on_fail()
             sock.close()
 

coolamqp/uplink/listener/thread.py

@@ -14,7 +14,7 @@ class ListenerThread(threading.Thread):
     """
 
     def __init__(self):
-        threading.Thread.__init__(self)
+        threading.Thread.__init__(self, name='coolamqp/ListenerThread')
         self.daemon = True
         self.terminating = False
         self.listener = EpollListener()