From 29f2c3c581a840bef928a53226f3f9e6ac2f1ffc Mon Sep 17 00:00:00 2001 From: Maciej Walkowiak Date: Sun, 22 Sep 2024 22:54:12 +0200 Subject: [PATCH] Fix formatting (#1230) --- .../s3/DiskBufferingS3OutputStreamTests.java | 2 +- .../io/awspring/cloud/sns/core/SnsOperations.java | 2 +- .../io/awspring/cloud/sns/core/SnsTemplate.java | 5 +++-- .../integration/SnsTemplateIntegrationTest.java | 15 +++++++-------- 4 files changed, 12 insertions(+), 12 deletions(-) diff --git a/spring-cloud-aws-s3/src/test/java/io/awspring/cloud/s3/DiskBufferingS3OutputStreamTests.java b/spring-cloud-aws-s3/src/test/java/io/awspring/cloud/s3/DiskBufferingS3OutputStreamTests.java index 4e746f367..46da0a256 100644 --- a/spring-cloud-aws-s3/src/test/java/io/awspring/cloud/s3/DiskBufferingS3OutputStreamTests.java +++ b/spring-cloud-aws-s3/src/test/java/io/awspring/cloud/s3/DiskBufferingS3OutputStreamTests.java @@ -76,7 +76,7 @@ void abortsWhenExplicitlyInvoked() throws IOException { S3Client s3Client = mock(S3Client.class); try (DiskBufferingS3OutputStream diskBufferingS3OutputStream = new DiskBufferingS3OutputStream( - new Location("bucket", "key"), s3Client, null)) { + new Location("bucket", "key"), s3Client, null)) { diskBufferingS3OutputStream.write("hello".getBytes(StandardCharsets.UTF_8)); diskBufferingS3OutputStream.abort(); } diff --git a/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsOperations.java b/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsOperations.java index fc129e3c9..be9803228 100644 --- a/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsOperations.java +++ b/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsOperations.java @@ -31,7 +31,7 @@ public interface SnsOperations { * @param notification - the notification */ void sendNotification(String topic, SnsNotification notification); - + /** * Checks if topic with given ARN exists. * diff --git a/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsTemplate.java b/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsTemplate.java index f769e7005..7a099bbba 100644 --- a/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsTemplate.java +++ b/spring-cloud-aws-sns/src/main/java/io/awspring/cloud/sns/core/SnsTemplate.java @@ -153,13 +153,14 @@ public void addChannelInterceptor(ChannelInterceptor channelInterceptor) { public void sendNotification(String topic, SnsNotification notification) { this.convertAndSend(topic, notification.getPayload(), notification.getHeaders()); } - + @Override public boolean topicExists(String topicArn) { Assert.notNull(topicArn, "topicArn must not be null"); try { snsClient.getTopicAttributes(request -> request.topicArn(topicArn)); - } catch (NotFoundException exception) { + } + catch (NotFoundException exception) { return false; } return true; diff --git a/spring-cloud-aws-sns/src/test/java/io/awspring/cloud/sns/integration/SnsTemplateIntegrationTest.java b/spring-cloud-aws-sns/src/test/java/io/awspring/cloud/sns/integration/SnsTemplateIntegrationTest.java index dbcd2c8e1..1b3b4825c 100644 --- a/spring-cloud-aws-sns/src/test/java/io/awspring/cloud/sns/integration/SnsTemplateIntegrationTest.java +++ b/spring-cloud-aws-sns/src/test/java/io/awspring/cloud/sns/integration/SnsTemplateIntegrationTest.java @@ -24,10 +24,9 @@ import io.awspring.cloud.sns.core.SnsTemplate; import io.awspring.cloud.sns.core.TopicNotFoundException; import io.awspring.cloud.sns.core.TopicsListingTopicArnResolver; -import net.bytebuddy.utility.RandomString; - import java.util.HashMap; import java.util.Map; +import net.bytebuddy.utility.RandomString; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.Nested; @@ -206,24 +205,24 @@ private static void createTopics() { } } } - + @Test void shouldReturnFalseForNonExistingTopic() { String nonExistentTopicArn = String.format("arn:aws:sns:us-east-1:000000000000:%s", RandomString.make()); - + boolean response = snsTemplate.topicExists(nonExistentTopicArn); - + assertThat(response).isFalse(); } - + @Test void shouldReturnTrueForExistingTopic() { String topicName = RandomString.make(); snsClient.createTopic(request -> request.name(topicName)); String topicArn = String.format("arn:aws:sns:us-east-1:000000000000:%s", topicName); - + boolean response = snsTemplate.topicExists(topicArn); - + assertThat(response).isTrue(); }