Merge pull request #124 from francoispluchino/fix-sqs-fifo-topic

Fix invalid SNS topic names with FIFO SQS queues
uecode · Oct 9, 2017 · ecde4cb · ecde4cb
2 parents cf6b3ac + 86879ea
commit ecde4cb
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/Provider/AwsProvider.php b/src/Provider/AwsProvider.php
@@ -508,13 +508,14 @@ public function createTopic()
             return false;
         }
 
+        $name = str_replace('.', '-', $this->getNameWithPrefix());
         $result = $this->sns->createTopic([
-            'Name' => $this->getNameWithPrefix()
+            'Name' => $name
         ]);
 
         $this->topicArn = $result->get('TopicArn');
 
-        $key = $this->getNameWithPrefix() . '_arn';
+        $key = $name . '_arn';
         $this->cache->save($key, $this->topicArn);
 
         $this->log(200, "Created SNS Topic", ['TopicARN' => $this->topicArn]);