From 4e00985ca52da6214b656ecd7568523fd88eeec4 Mon Sep 17 00:00:00 2001 From: Corneil du Plessis Date: Fri, 20 Oct 2023 17:05:30 +0200 Subject: [PATCH] Fix S3 Source Integration tests. --- .../fn/supplier/s3/AwsS3SupplierConfiguration.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/supplier/s3-supplier/src/main/java/org/springframework/cloud/fn/supplier/s3/AwsS3SupplierConfiguration.java b/supplier/s3-supplier/src/main/java/org/springframework/cloud/fn/supplier/s3/AwsS3SupplierConfiguration.java index 5ad44a6b..be44f4fd 100644 --- a/supplier/s3-supplier/src/main/java/org/springframework/cloud/fn/supplier/s3/AwsS3SupplierConfiguration.java +++ b/supplier/s3-supplier/src/main/java/org/springframework/cloud/fn/supplier/s3/AwsS3SupplierConfiguration.java @@ -208,9 +208,12 @@ public class AwsS3SupplierConfiguration { } @Bean - ReactiveMessageSourceProducer s3ListingMessageProducer(S3Client amazonS3, ObjectMapper objectMapper, - AwsS3SupplierProperties awsS3SupplierProperties, Predicate filter) { - + ReactiveMessageSourceProducer s3ListingMessageProducer( + S3Client amazonS3, + ObjectMapper objectMapper, + AwsS3SupplierProperties awsS3SupplierProperties, + Predicate filter + ) { return new ReactiveMessageSourceProducer( (MessageSource>) () -> { List summaryList = @@ -232,7 +235,5 @@ public class AwsS3SupplierConfiguration { return summaryList.isEmpty() ? null : new GenericMessage<>(summaryList); }); } - } - }