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)