From 0866a8f61f56c41e55dcd54cce428b7096b0fa75 Mon Sep 17 00:00:00 2001 From: Baqirrizvidev <114152937+Baqirrizvidev@users.noreply.github.com> Date: Mon, 25 May 2026 11:29:20 +0530 Subject: [PATCH] refactor(sqs): modernize stream collector in QueueMessageVisibility --- .../io/awspring/cloud/sqs/listener/QueueMessageVisibility.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/QueueMessageVisibility.java b/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/QueueMessageVisibility.java index 637892ff6f..e1840b0e7e 100644 --- a/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/QueueMessageVisibility.java +++ b/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/QueueMessageVisibility.java @@ -18,7 +18,6 @@ import io.awspring.cloud.sqs.MessageHeaderUtils; import java.util.Collection; import java.util.concurrent.CompletableFuture; -import java.util.stream.Collectors; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.messaging.Message; @@ -61,7 +60,7 @@ public QueueMessageVisibility(SqsAsyncClient amazonSqsAsync, String queueUrl, St public BatchVisibility toBatchVisibility(Collection> messages) { return new QueueMessageBatchVisibility(this.sqsAsyncClient, this.queueUrl, messages.stream().map( message -> MessageHeaderUtils.getHeader(message, SqsHeaders.SQS_RECEIPT_HANDLE_HEADER, String.class)) - .collect(Collectors.toList())); + .toList()); } @Override