From 49af7fc0cecfebcec4c93b3dc76b2d41a850f515 Mon Sep 17 00:00:00 2001 From: Baqirrizvidev <114152937+Baqirrizvidev@users.noreply.github.com> Date: Mon, 25 May 2026 11:29:59 +0530 Subject: [PATCH] refactor(sns): modernize stream collector in SnsBatchTemplate --- .../io/awspring/cloud/sns/core/batch/SnsBatchTemplate.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/batch/SnsBatchTemplate.java b/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/batch/SnsBatchTemplate.java index b4e79c9b3..90946d8f1 100644 --- a/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/batch/SnsBatchTemplate.java +++ b/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/batch/SnsBatchTemplate.java @@ -20,7 +20,6 @@ import io.awspring.cloud.sns.core.batch.converter.SnsMessageConverter; import io.awspring.cloud.sns.core.batch.executor.BatchExecutionStrategy; import java.util.Collection; -import java.util.stream.Collectors; import org.springframework.messaging.Message; import org.springframework.messaging.support.MessageBuilder; import org.springframework.util.Assert; @@ -81,7 +80,7 @@ public BatchResult convertAndSend(String topicName, Collection payloads) Assert.notNull(topicName, "topicName is required"); Assert.notNull(payloads, "payloads are required"); var batchList = payloads.stream().map(it -> MessageBuilder.withPayload(it).build()) - .map(snsMessageConverter::convertMessage).collect(Collectors.toList()); + .map(snsMessageConverter::convertMessage).toList(); return batchExecutionStrategy.send(topicArnResolver.resolveTopicArn(topicName), batchList); } @@ -100,7 +99,7 @@ public BatchResult sendBatchNotifications(String topicName, Collection MessageBuilder.withPayload(it.getPayload()).copyHeaders(it.getHeaders()).build()) - .map(snsMessageConverter::convertMessage).collect(Collectors.toList()); + .map(snsMessageConverter::convertMessage).toList(); return batchExecutionStrategy.send(topicArnResolver.resolveTopicArn(topicName), batchList); }