You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2026/04/02 08:30:00 UTC
(pekko-connectors) branch main updated: sqs: update call due to deprecation warning (#762)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new d35e64c8e sqs: update call due to deprecation warning (#762)
d35e64c8e is described below
commit d35e64c8e8af5e9a44dc6c568b7e5cbcb0869193
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Thu Apr 2 10:29:54 2026 +0200
sqs: update call due to deprecation warning (#762)
---
.../org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSource.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSource.scala b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSource.scala
index c98c3118a..e9fd42351 100644
--- a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSource.scala
+++ b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsSource.scala
@@ -44,7 +44,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)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org