Allow queue and topic name to end with .fifo
@@ -281,7 +281,7 @@ class AWSSNSSQSTransport(Invoker):
def validate_queue_name(cls, queue_name: str) -> None:
if len(queue_name) > 80:
raise Exception("Queue name ({}) is too long.".format(queue_name))
- if not set(queue_name) <= set(string.digits + string.ascii_letters + "-" + "_"):
+ if not set(queue_name.rstrip(".fifo")) <= set(string.digits + string.ascii_letters + "-" + "_"):
raise Exception(
"Queue name ({}) may only contain alphanumeric characters, hyphens (-), and underscores (_).".format(
queue_name
@@ -292,7 +292,7 @@ class AWSSNSSQSTransport(Invoker):
def validate_topic_name(cls, topic: str) -> None:
if len(topic) > 256:
raise Exception("Topic name ({}) is too long.".format(topic))
- if not set(topic) <= set(string.digits + string.ascii_letters + "-" + "_"):
+ if not set(topic.rstrip(".fifo")) <= set(string.digits + string.ascii_letters + "-" + "_"):
raise Exception(
"Topic name ({}) may only contain alphanumeric characters, hyphens (-), and underscores (_).".format(
topic
