Skip to content

Commit

Permalink
Formatting (#1095)
Browse files Browse the repository at this point in the history
  • Loading branch information
maciejwalkowiak authored Mar 15, 2024
1 parent 3643a9b commit 86b13b4
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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;
Expand Down Expand Up @@ -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<SampleRecord> result = template.send(RECORD_WITHOUT_TYPE_HEADER_QUEUE_NAME, testRecord);
Expand Down

0 comments on commit 86b13b4

Please sign in to comment.