From 5593505dd9deea5d0089d03cddfb3728f09a2048 Mon Sep 17 00:00:00 2001 From: jkoehl Date: Wed, 30 Aug 2017 10:36:57 -0400 Subject: [PATCH] Fixes #791 --- kombu/transport/SQS.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kombu/transport/SQS.py b/kombu/transport/SQS.py index 97b4a2dc..66251e80 100644 --- a/kombu/transport/SQS.py +++ b/kombu/transport/SQS.py @@ -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)