diff --git a/coolamqp/backends/__init__.py b/coolamqp/backends/__init__.py index d588907fe39bcc2ba005519b8da003e17c692c2d..27a3401e33ca65e1efe8f8359c5a260f115bb784 100644 --- a/coolamqp/backends/__init__.py +++ b/coolamqp/backends/__init__.py @@ -1,2 +1,2 @@ from .pyamqp import PyAMQPBackend -from .base import AMQPError, ConnectionFailedError, RemoteAMQPError \ No newline at end of file +from .base import AMQPError, ConnectionFailedError, RemoteAMQPError diff --git a/coolamqp/backends/base.py b/coolamqp/backends/base.py index a8d6e73308f4be055810b6664ab872ce6379c9ea..090b39ec5da6d4b71c571d067c09f13838d8b7fd 100644 --- a/coolamqp/backends/base.py +++ b/coolamqp/backends/base.py @@ -114,4 +114,4 @@ class AMQPBackend(object): Close this connection. This is not allowed to return anything. """ - self.cluster_handler_thread = None # break GC cycles \ No newline at end of file + self.cluster_handler_thread = None # break GC cycles diff --git a/coolamqp/backends/pyamqp.py b/coolamqp/backends/pyamqp.py index a6896e681a5897441c513a1c80a6812a6a022ea5..0338f082174c6e4b7c3ef3c43ab4d94aa0f8fa00 100644 --- a/coolamqp/backends/pyamqp.py +++ b/coolamqp/backends/pyamqp.py @@ -128,4 +128,3 @@ class PyAMQPBackend(AMQPBackend): message.delivery_info['routing_key'], message.delivery_info['delivery_tag'], message.properties) - diff --git a/coolamqp/events.py b/coolamqp/events.py index 334dcebec5ff20ced72bebdac4a2b1cd2e13ce73..20a246da40aefa54828bbee6e31afe8c75be6e38 100644 --- a/coolamqp/events.py +++ b/coolamqp/events.py @@ -31,4 +31,4 @@ class ConsumerCancelled(ClusterEvent): """ :param queue: Queue whose consumer was cancelled """ - self.queue = queue \ No newline at end of file + self.queue = queue diff --git a/coolamqp/messages.py b/coolamqp/messages.py index 9579485b49beba731afeec68720c574ecfe2cf5f..edd8f393000ec50d3f22a47d49dcfa7ac1a63eae 100644 --- a/coolamqp/messages.py +++ b/coolamqp/messages.py @@ -107,4 +107,3 @@ class Queue(object): self.anonymous = name == '' # if this queue is anonymous, it must be regenerated upon reconnect self.consumer_tag = name if name != '' else uuid.uuid4().hex # consumer tag to use in AMQP comms -