From 0f640ef358335efbc8bdb2cae5c32b77f174ffba Mon Sep 17 00:00:00 2001 From: Sebastian Date: Mon, 30 Sep 2024 13:34:16 +0200 Subject: [PATCH] use messageSystemAttributeNamesWithStrings --- .../main/scala/akka/stream/alpakka/sqs/scaladsl/SqsSource.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sqs/src/main/scala/akka/stream/alpakka/sqs/scaladsl/SqsSource.scala b/sqs/src/main/scala/akka/stream/alpakka/sqs/scaladsl/SqsSource.scala index c8ef8df269..495c2917dd 100644 --- a/sqs/src/main/scala/akka/stream/alpakka/sqs/scaladsl/SqsSource.scala +++ b/sqs/src/main/scala/akka/stream/alpakka/sqs/scaladsl/SqsSource.scala @@ -34,7 +34,7 @@ object SqsSource { ReceiveMessageRequest .builder() .queueUrl(queueUrl) - .attributeNamesWithStrings(settings.attributeNames.map(_.name).asJava) + .messageSystemAttributeNamesWithStrings(settings.attributeNames.map(_.name).asJava) .messageAttributeNames(settings.messageAttributeNames.map(_.name).asJava) .maxNumberOfMessages(settings.maxBatchSize) .waitTimeSeconds(settings.waitTimeSeconds)