Skip to content

Commit 86879ea

Browse files
Fix invalid SNS topic names with FIFO SQS queues
1 parent cf6b3ac commit 86879ea

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/Provider/AwsProvider.php

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -508,13 +508,14 @@ public function createTopic()
508508
return false;
509509
}
510510

511+
$name = str_replace('.', '-', $this->getNameWithPrefix());
511512
$result = $this->sns->createTopic([
512-
'Name' => $this->getNameWithPrefix()
513+
'Name' => $name
513514
]);
514515

515516
$this->topicArn = $result->get('TopicArn');
516517

517-
$key = $this->getNameWithPrefix() . '_arn';
518+
$key = $name . '_arn';
518519
$this->cache->save($key, $this->topicArn);
519520

520521
$this->log(200, "Created SNS Topic", ['TopicARN' => $this->topicArn]);

0 commit comments

Comments
 (0)