Акка Алпакка SqsSource как ни странно может работать с queueUrl, а также с queueName - PullRequest
0 голосов
/ 26 января 2020

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

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

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

SqsSource(queue.getUrl)

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

SqsSource(queueName)

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

Префикс url одинаков для всех очередей, поэтому я решил, что у alpakka или AmazonSQSAsyn c есть некоторые неявные для этого или что-то, кто-то знает, как это объяснить? спасибо

1 Ответ

1 голос
/ 27 января 2020

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

...