Как ни странно, Akka Alpakka SqsSource может работать с queueUrl, а также с queueName

Я использую Akka Streams, а также alpakka.sqs.scaladsl для чтения сообщений из очереди sqs.

Я делал это много раз, но теперь я загрузил версию, в которой имя очереди помещалось в источник вместо URL-адреса очереди, как я делал это все время.

вот как я это делал раньше:

SqsSource(queue.getUrl)

и теперь я сделал это:

SqsSource(queueName)

оба случая работают..

префикс URL-адреса идентичен для всех очередей, поэтому я решил, что либо alpakka, либо AmazonSQSAsync имеют для этого какое-то неявное значение или что-то в этом роде, кто-нибудь знает, как это объяснить? Благодарность


person JohnBigs    schedule 26.01.2020    source источник


Ответы (1)


Alpakka не делает ничего особенного с URL-адресом очереди. Строка передается в AWS SQS в неизменном виде, который разрешает ее.

person Enno    schedule 27.01.2020