我正在使用Akka Streams,还使用alpakka.sqs.scaladsl从sqs队列中读取消息。
我已经做过很多次了,但是现在我上传了一个版本,该版本将队列名称而不是队列URL放置在源代码中,这就是我一直以来的做法。
这是我之前的做法:
SqsSource(queue.getUrl)
现在我做到了:
SqsSource(queueName)
两种情况都有效。.
URL前缀在所有队列之间都是相同的,所以我认为alpakka或AmazonSQSAsync对此具有某种隐式含义,有人知道如何解释吗?谢谢
Alpakka对队列URL并没有做任何特别的事情。该字符串会原样传递到AWS SQS,从而解决该问题。