diff --git a/coolamqp/cluster.py b/coolamqp/cluster.py index bd85db9720f9283e569e98ac38a5e92c7126276f..bd64179682617b8bb2945713f49ed02441bc14c9 100644 --- a/coolamqp/cluster.py +++ b/coolamqp/cluster.py @@ -180,4 +180,3 @@ class Cluster(object): """ self.thread.terminate() self.thread.join() - return diff --git a/coolamqp/handler.py b/coolamqp/handler.py index 15d0ec517844d8a1099ab434c570adb6edc29390..f7567a860d4e4e24c6564c4dc342bf0595cf6ba6 100644 --- a/coolamqp/handler.py +++ b/coolamqp/handler.py @@ -158,7 +158,6 @@ class ClusterHandlerThread(threading.Thread): """ self.is_terminating = True - ## events called def _on_recvmessage(self, body, exchange_name, routing_key, delivery_tag, properties): """