Class FileSystemPersistentAcceptOnceFileListFilter
java.lang.Object
org.springframework.integration.file.filters.AbstractFileListFilter<F>
org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<java.io.File>
org.springframework.integration.file.filters.FileSystemPersistentAcceptOnceFileListFilter
- All Implemented Interfaces:
java.io.Closeable,java.lang.AutoCloseable,FileListFilter<java.io.File>,ResettableFileListFilter<java.io.File>,ReversibleFileListFilter<java.io.File>
public class FileSystemPersistentAcceptOnceFileListFilter extends AbstractPersistentAcceptOnceFileListFilter<java.io.File>
- Since:
- 3.0
-
Field Summary
Fields inherited from class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter
flushableStore, flushOnUpdate, prefix, store -
Constructor Summary
Constructors Constructor Description FileSystemPersistentAcceptOnceFileListFilter(org.springframework.integration.metadata.ConcurrentMetadataStore store, java.lang.String prefix) -
Method Summary
Modifier and Type Method Description protected java.lang.StringfileName(java.io.File file)protected booleanfileStillExists(java.io.File file)Check that the file still exists, to avoid a race condition when multi-threaded and another thread removed the file while we were waiting for the lock.protected longmodified(java.io.File file)Methods inherited from class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter
accept, buildKey, close, flushIfNeeded, isEqual, remove, rollback, setFlushOnUpdateMethods inherited from class org.springframework.integration.file.filters.AbstractFileListFilter
filterFiles, supportsSingleFileFilteringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.integration.file.filters.FileListFilter
filterFiles, supportsSingleFileFiltering
-
Constructor Details
-
FileSystemPersistentAcceptOnceFileListFilter
public FileSystemPersistentAcceptOnceFileListFilter(org.springframework.integration.metadata.ConcurrentMetadataStore store, java.lang.String prefix)
-
-
Method Details
-
modified
protected long modified(java.io.File file)- Specified by:
modifiedin classAbstractPersistentAcceptOnceFileListFilter<java.io.File>
-
fileName
protected java.lang.String fileName(java.io.File file)- Specified by:
fileNamein classAbstractPersistentAcceptOnceFileListFilter<java.io.File>
-
fileStillExists
protected boolean fileStillExists(java.io.File file)Check that the file still exists, to avoid a race condition when multi-threaded and another thread removed the file while we were waiting for the lock.- Overrides:
fileStillExistsin classAbstractPersistentAcceptOnceFileListFilter<java.io.File>- Parameters:
file- the file.- Returns:
- true if the filter should return true.
- Since:
- 4.3.19
-