We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 600f0ba commit 305250eCopy full SHA for 305250e
sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSource.scala
@@ -43,7 +43,7 @@ object SqsSource {
43
ReceiveMessageRequest
44
.builder()
45
.queueUrl(queueUrl)
46
- .attributeNamesWithStrings(settings.attributeNames.map(_.name).asJava)
+ .messageSystemAttributeNamesWithStrings(settings.attributeNames.map(_.name).asJava)
47
.messageAttributeNames(settings.messageAttributeNames.map(_.name).asJava)
48
.maxNumberOfMessages(settings.maxBatchSize)
49
.waitTimeSeconds(settings.waitTimeSeconds)
0 commit comments