use messageSystemAttributeNamesWithStrings

akka · Oct 1, 2024 · 0f640ef · 0f640ef
1 parent 67338ca
commit 0f640ef
Showing 1 changed file with 1 addition and 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
@@ -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)