Skip to content
Snippets Groups Projects
Commit d9a603c3 authored by John Chilton's avatar John Chilton
Browse files

Fix linting problem.

parent ce0636a5
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
pulsar/client/amqp_exchange.py
+ 2
− 2
View file @ d9a603c3
...@@ -186,8 +186,8 @@ class PulsarExchange(object): ...@@ -186,8 +186,8 @@ class PulsarExchange(object):
key = self.__queue_name(name) key = self.__queue_name(name)
publish_log_prefix = self.__publish_log_prefex(transaction_uuid) publish_log_prefix = self.__publish_log_prefex(transaction_uuid)
log.debug("%sBegin publishing to key %s", publish_log_prefix, key) log.debug("%sBegin publishing to key %s", publish_log_prefix, key)
if (self.acks_enabled and not name.endswith(ACK_QUEUE_SUFFIX) if (self.acks_enabled and not name.endswith(ACK_QUEUE_SUFFIX) and
and ACK_FORCE_NOACK_KEY not in payload): ACK_FORCE_NOACK_KEY not in payload):
# Publishing a message on a normal queue and it's not a republish # Publishing a message on a normal queue and it's not a republish
# (or explicitly forced do-not-ack), so add ack keys # (or explicitly forced do-not-ack), so add ack keys
ack_uuid = str(transaction_uuid) ack_uuid = str(transaction_uuid)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment