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); }