From f1804c538938dcc82557e9b32d13e24560890291 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl> Date: Sat, 28 May 2016 23:56:28 +0200 Subject: [PATCH] whitespaces because --- coolamqp/backends/__init__.py | 2 +- coolamqp/backends/base.py | 2 +- coolamqp/backends/pyamqp.py | 1 - coolamqp/events.py | 2 +- coolamqp/messages.py | 1 - 5 files changed, 3 insertions(+), 5 deletions(-) diff --git a/coolamqp/backends/__init__.py b/coolamqp/backends/__init__.py index d588907..27a3401 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 a8d6e73..090b39e 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 a6896e6..0338f08 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 334dceb..20a246d 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 9579485..edd8f39 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 - -- GitLab