rename

Author: MatejNedic

spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/batch/SnsBatchTemplate.java

@@ -20,14 +20,9 @@
 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.List;
-import java.util.Map;
 import java.util.stream.Collectors;
 
-import org.jspecify.annotations.Nullable;
 import org.springframework.messaging.Message;
-import org.springframework.messaging.MessagingException;
-import org.springframework.messaging.core.MessagePostProcessor;
 import org.springframework.messaging.support.MessageBuilder;
 import org.springframework.util.Assert;
 
@@ -70,7 +65,7 @@ public <T> BatchResult sendBatch(String topicName, Collection<Message<T>> messag
 		Assert.notNull(topicName, "topicName is required");
 		Assert.notNull(messages, "messages are required");
 
-		var batchList = messages.stream().map(snsMessageConverter::covertMessage).toList();
+		var batchList = messages.stream().map(snsMessageConverter::convertMessage).toList();
 		return batchExecutionStrategy.send(topicArnResolver.resolveTopicArn(topicName), batchList);
 	}
 
@@ -86,7 +81,7 @@ public <T> BatchResult sendBatch(String topicName, Collection<Message<T>> messag
 	public <T> BatchResult convertAndSend(String topicName, Collection<T> 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::covertMessage).collect(Collectors.toList());
+		var batchList = payloads.stream().map(it -> MessageBuilder.withPayload(it).build()).map(snsMessageConverter::convertMessage).collect(Collectors.toList());
 		return batchExecutionStrategy.send(topicArnResolver.resolveTopicArn(topicName), batchList);
 	}
 
@@ -103,7 +98,7 @@ public <T> BatchResult convertAndSend(String topicName, Collection<T> payloads)
 	public <T> BatchResult sendBatchNotifications(String topicName, Collection<SnsNotification<T>> notifications) {
 		Assert.notNull(topicName, "topicName is required");
 		Assert.notNull(notifications, "notifications are required");
-		var batchList = notifications.stream().map(it -> MessageBuilder.withPayload(it.getPayload()).copyHeaders(it.getHeaders()).build()).map(snsMessageConverter::covertMessage).collect(Collectors.toList());
+		var batchList = notifications.stream().map(it -> MessageBuilder.withPayload(it.getPayload()).copyHeaders(it.getHeaders()).build()).map(snsMessageConverter::convertMessage).collect(Collectors.toList());
 		return batchExecutionStrategy.send(topicArnResolver.resolveTopicArn(topicName), batchList);
 	}
 

spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/batch/converter/DefaultSnsMessageConverter.java

@@ -78,7 +78,7 @@ private static CompositeMessageConverter initMessageConverter(@Nullable MessageC
 	 * @return PublishBatchRequestEntry ready to be included in a batch publish request
 	 */
 	@Override
-	public <T> PublishBatchRequestEntry covertMessage(Message<T> originalMessage) {
+	public <T> PublishBatchRequestEntry convertMessage(Message<T> originalMessage) {
 		PublishBatchRequestEntry.Builder publishBatchRequestEntry = PublishBatchRequestEntry.builder();
 		populateHeader(publishBatchRequestEntry, originalMessage);
 		Message<?> message = messageConverter.toMessage(originalMessage.getPayload(), originalMessage.getHeaders());

spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/batch/converter/SnsMessageConverter.java

@@ -33,6 +33,6 @@ public interface SnsMessageConverter {
 	 * @param <T> The type of the message payload
 	 * @return PublishBatchRequestEntry ready to be included in a batch publish request
 	 */
-	<T> PublishBatchRequestEntry covertMessage(Message<T> message);
+	<T> PublishBatchRequestEntry convertMessage(Message<T> message);
 
 }

spring-cloud-aws-sns/src/test/java/io/awspring/cloud/sns/core/batch/converter/DefaultSnsMessageConverterTest.java

@@ -41,7 +41,7 @@ class DefaultSnsMessageConverterTest {
 	void convertsStringPayload() {
 		Message<String> message = MessageBuilder.withPayload("hello").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.message()).isEqualTo("hello");
 	}
@@ -54,7 +54,7 @@ void convertsJsonPayloadWithCustomConverter() {
 
 		Message<Person> message = MessageBuilder.withPayload(new Person("John")).build();
 
-		PublishBatchRequestEntry entry = jsonConverter.covertMessage(message);
+		PublishBatchRequestEntry entry = jsonConverter.convertMessage(message);
 
 		assertThat(entry.message()).contains("John");
 	}
@@ -64,7 +64,7 @@ void setsMessageGroupId() {
 		Message<String> message = MessageBuilder.withPayload("test")
 				.setHeader(SnsHeaders.MESSAGE_GROUP_ID_HEADER, "group-1").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.messageGroupId()).isEqualTo("group-1");
 	}
@@ -74,7 +74,7 @@ void setsDeduplicationId() {
 		Message<String> message = MessageBuilder.withPayload("test")
 				.setHeader(SnsHeaders.MESSAGE_DEDUPLICATION_ID_HEADER, "dedup-1").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.messageDeduplicationId()).isEqualTo("dedup-1");
 	}
@@ -86,7 +86,7 @@ void setsAllFifoHeaders() {
 				.setHeader(SnsHeaders.MESSAGE_DEDUPLICATION_ID_HEADER, "ded")
 				.setHeader("custom", "val").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.message()).isEqualTo("fifo payload");
 		assertThat(entry.messageGroupId()).isEqualTo("grp");
@@ -99,7 +99,7 @@ void setsAllFifoHeaders() {
 	void leavesOptionalHeadersNullWhenAbsent() {
 		Message<String> message = MessageBuilder.withPayload("plain").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.messageGroupId()).isNull();
 		assertThat(entry.messageDeduplicationId()).isNull();
@@ -110,7 +110,7 @@ void convertsCustomHeadersToMessageAttributes() {
 		Message<String> message = MessageBuilder.withPayload("test")
 				.setHeader("priority", "high").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.messageAttributes()).containsKey("priority");
 		//Test plain String value\
@@ -122,7 +122,7 @@ void usesCustomMessageIdHeaderAsBatchEntryId() {
 		Message<String> message = MessageBuilder.withPayload("test")
 				.setHeader(SnsHeaders.MESSAGE_ID_HEADER, "custom-id-123").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.id()).isEqualTo("custom-id-123");
 	}
@@ -131,7 +131,7 @@ void usesCustomMessageIdHeaderAsBatchEntryId() {
 	void generatesUuidWhenNoMessageIdHeader() {
 		Message<String> message = MessageBuilder.withPayload("test").build();
 
-		PublishBatchRequestEntry entry = converter.covertMessage(message);
+		PublishBatchRequestEntry entry = converter.convertMessage(message);
 
 		assertThat(entry.id()).isNotBlank();
 		assertThat(UUID.fromString(entry.id())).isNotNull();