Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes #791

This commit is contained in:
jkoehl 2017-08-30 10:36:57 -04:00
parent 16ea4df217
commit 5593505dd9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kombu/transport/SQS.py
View File

@ -154,10 +154,10 @@ class Channel(virtual.Channel):
"""Format AMQP queue name into a legal SQS queue name."""
if name.endswith('.fifo'):
partial = name.rstrip('.fifo')
partial = text_t(safe_str(partial)).translate(table)
partial = text_t(safe_str(partial.translate(table)))
return partial + '.fifo'
else:
return text_t(safe_str(name)).translate(table)
return text_t(safe_str(name.translate(table)))
def canonical_queue_name(self, queue_name):
return self.entity_name(self.queue_name_prefix + queue_name)