diff --git a/spring-integration-file/src/main/java/org/springframework/integration/file/filters/CompositeFileListFilter.java b/spring-integration-file/src/main/java/org/springframework/integration/file/filters/CompositeFileListFilter.java index 7019884521..35d1bb1891 100644 --- a/spring-integration-file/src/main/java/org/springframework/integration/file/filters/CompositeFileListFilter.java +++ b/spring-integration-file/src/main/java/org/springframework/integration/file/filters/CompositeFileListFilter.java @@ -65,8 +65,8 @@ public class CompositeFileListFilter public CompositeFileListFilter(Collection> fileFilters) { this.fileFilters = new LinkedHashSet<>(fileFilters); - this.allSupportAccept = fileFilters.stream().allMatch(FileListFilter::supportsSingleFileFiltering); - this.oneIsForRecursion = fileFilters.stream().anyMatch(FileListFilter::isForRecursion); + this.allSupportAccept = fileFilters.stream().allMatch(FileListFilter::supportsSingleFileFiltering); + this.oneIsForRecursion = fileFilters.stream().anyMatch(FileListFilter::isForRecursion); } @Override diff --git a/spring-integration-file/src/test/java/org/springframework/integration/file/filters/PersistentAcceptOnceFileListFilterTests.java b/spring-integration-file/src/test/java/org/springframework/integration/file/filters/PersistentAcceptOnceFileListFilterTests.java index 1030c32471..e8782ac4d5 100644 --- a/spring-integration-file/src/test/java/org/springframework/integration/file/filters/PersistentAcceptOnceFileListFilterTests.java +++ b/spring-integration-file/src/test/java/org/springframework/integration/file/filters/PersistentAcceptOnceFileListFilterTests.java @@ -99,7 +99,7 @@ public class PersistentAcceptOnceFileListFilterTests extends AcceptOnceFileListF @Test public void testRollback() { AbstractPersistentAcceptOnceFileListFilter filter = - new AbstractPersistentAcceptOnceFileListFilter<>(new SimpleMetadataStore(), "rollback:") { + new AbstractPersistentAcceptOnceFileListFilter(new SimpleMetadataStore(), "rollback:") { @Override protected long modified(String file) {