diff --git a/spring-integration-adapters/src/main/java/org/springframework/integration/adapter/file/FileSource.java b/spring-integration-adapters/src/main/java/org/springframework/integration/adapter/file/FileSource.java index 5cdc2ed54a..1ab54c6bbb 100644 --- a/spring-integration-adapters/src/main/java/org/springframework/integration/adapter/file/FileSource.java +++ b/spring-integration-adapters/src/main/java/org/springframework/integration/adapter/file/FileSource.java @@ -69,10 +69,12 @@ public class FileSource implements PollableSource { throw new MessageHandlingException("Problem occurred while polling for files. " + "Is '" + directory.getAbsolutePath() + "' a directory?"); } + List results = new ArrayList(); int size = Math.min(limit, files.length); - List results = new ArrayList(size); for (int i = 0; i < size; i++) { - results.add(files[i]); + if (files[i].isFile()) { + results.add(files[i]); + } } return results; }