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 637892ff6..e1840b0e7 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