diff --git a/spring-cloud-aws-sqs/src/test/java/io/awspring/cloud/sqs/integration/SqsTemplateIntegrationTests.java b/spring-cloud-aws-sqs/src/test/java/io/awspring/cloud/sqs/integration/SqsTemplateIntegrationTests.java index 3c9bf5a5c..ebaacec1c 100644 --- a/spring-cloud-aws-sqs/src/test/java/io/awspring/cloud/sqs/integration/SqsTemplateIntegrationTests.java +++ b/spring-cloud-aws-sqs/src/test/java/io/awspring/cloud/sqs/integration/SqsTemplateIntegrationTests.java @@ -24,6 +24,7 @@ import io.awspring.cloud.sqs.operations.SqsTemplate; import io.awspring.cloud.sqs.operations.SqsTemplateParameters; import io.awspring.cloud.sqs.operations.TemplateAcknowledgementMode; +import io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter; import java.time.Duration; import java.util.ArrayList; import java.util.Collection; @@ -32,8 +33,6 @@ import java.util.Optional; import java.util.concurrent.CompletableFuture; import java.util.stream.IntStream; - -import io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter; import org.assertj.core.api.InstanceOfAssertFactories; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.Test; @@ -307,8 +306,7 @@ void shouldSendAndReceiveBatchFifo() { @Test void shouldSendAndReceiveRecordMessageWithoutPayloadInfoHeader() { SqsTemplate template = SqsTemplate.builder().sqsAsyncClient(this.asyncClient) - .configureDefaultConverter(AbstractMessagingMessageConverter::doNotSendPayloadTypeHeader) - .build(); + .configureDefaultConverter(AbstractMessagingMessageConverter::doNotSendPayloadTypeHeader).build(); SampleRecord testRecord = new SampleRecord("Hello world!", "From shouldSendAndReceiveRecordMessageWithoutPayloadInfoHeader!"); SendResult result = template.send(RECORD_WITHOUT_TYPE_HEADER_QUEUE_NAME, testRecord);