SpringCloud/spring-functions-catalog
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix S3 Source Integration tests.

Browse Source
This commit is contained in:
Corneil du Plessis
2023-10-20 17:05:30 +02:00
parent 595f962128
commit 4e00985ca5
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
supplier/s3-supplier/src/main/java/org/springframework/cloud/fn/supplier/s3/AwsS3SupplierConfiguration.java
View File

@@ -208,9 +208,12 @@ public class AwsS3SupplierConfiguration {
}
@Bean
ReactiveMessageSourceProducer s3ListingMessageProducer(S3Client amazonS3, ObjectMapper objectMapper,
AwsS3SupplierProperties awsS3SupplierProperties, Predicate<S3Object> filter) {
ReactiveMessageSourceProducer s3ListingMessageProducer(
S3Client amazonS3,
ObjectMapper objectMapper,
AwsS3SupplierProperties awsS3SupplierProperties,
Predicate<S3Object> filter
) {
return new ReactiveMessageSourceProducer(
(MessageSource<List<String>>) () -> {
List<String> summaryList =
@@ -232,7 +235,5 @@ public class AwsS3SupplierConfiguration {
return summaryList.isEmpty() ? null : new GenericMessage<>(summaryList);
});
}
}
}