From d9a603c32cf3216b70576a27b0533e5c93eee8df Mon Sep 17 00:00:00 2001
From: John Chilton <jmchilton@gmail.com>
Date: Thu, 31 Mar 2016 12:21:16 -0400
Subject: [PATCH] Fix linting problem.
---
pulsar/client/amqp_exchange.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar/client/amqp_exchange.py b/pulsar/client/amqp_exchange.py
index 2ede16d8..03ad85ff 100644
--- a/pulsar/client/amqp_exchange.py
+++ b/pulsar/client/amqp_exchange.py
@@ -186,8 +186,8 @@ class PulsarExchange(object):
key = self.__queue_name(name)
publish_log_prefix = self.__publish_log_prefex(transaction_uuid)
log.debug("%sBegin publishing to key %s", publish_log_prefix, key)
- if (self.acks_enabled and not name.endswith(ACK_QUEUE_SUFFIX)
- and ACK_FORCE_NOACK_KEY not in payload):
+ if (self.acks_enabled and not name.endswith(ACK_QUEUE_SUFFIX) and
+ ACK_FORCE_NOACK_KEY not in payload):
# Publishing a message on a normal queue and it's not a republish
# (or explicitly forced do-not-ack), so add ack keys
ack_uuid = str(transaction_uuid)
--
GitLab