diff --git a/spring-integration-file/src/main/java/org/springframework/integration/file/FileReadingMessageSource.java b/spring-integration-file/src/main/java/org/springframework/integration/file/FileReadingMessageSource.java index 2463832d1f..d438b999c9 100644 --- a/spring-integration-file/src/main/java/org/springframework/integration/file/FileReadingMessageSource.java +++ b/spring-integration-file/src/main/java/org/springframework/integration/file/FileReadingMessageSource.java @@ -490,7 +490,7 @@ public class FileReadingMessageSource extends IntegrationObjectSupport implement } if (event.kind() == StandardWatchEventKinds.ENTRY_DELETE) { - if (getFilter() != null && getFilter() instanceof ResettableFileListFilter) { + if (getFilter() instanceof ResettableFileListFilter) { ((ResettableFileListFilter) getFilter()).remove(file); } boolean fileRemoved = files.remove(file);