Class S3PersistentAcceptOnceFileListFilter
java.lang.Object
org.springframework.integration.file.filters.AbstractFileListFilter<F>
org.springframework.integration.file.filters.AbstractDirectoryAwareFileListFilter<F>
org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<S3ObjectSummary>
org.springframework.integration.aws.support.filters.S3PersistentAcceptOnceFileListFilter
- All Implemented Interfaces:
Closeable,AutoCloseable,org.springframework.integration.file.filters.FileListFilter<S3ObjectSummary>,org.springframework.integration.file.filters.ResettableFileListFilter<S3ObjectSummary>,org.springframework.integration.file.filters.ReversibleFileListFilter<S3ObjectSummary>
public class S3PersistentAcceptOnceFileListFilter
extends org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<S3ObjectSummary>
Persistent file list filter using the server's file timestamp to detect if we've
already 'seen' this file.
- Author:
- Artem Bilan
-
Field Summary
Fields inherited from class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter
flushableStore, flushOnUpdate, prefix, store -
Constructor Summary
ConstructorsConstructorDescriptionS3PersistentAcceptOnceFileListFilter(org.springframework.integration.metadata.ConcurrentMetadataStore store, String prefix) -
Method Summary
Modifier and TypeMethodDescriptionprotected StringfileName(S3ObjectSummary file) protected booleanisDirectory(S3ObjectSummary file) Always return false since no directory notion in S3.protected longmodified(S3ObjectSummary file) Methods inherited from class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter
accept, buildKey, close, fileStillExists, flushIfNeeded, isEqual, remove, rollback, setFlushOnUpdateMethods inherited from class org.springframework.integration.file.filters.AbstractDirectoryAwareFileListFilter
alwaysAccept, isForRecursion, setAlwaysAcceptDirectories, setForRecursionMethods 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, isForRecursion, supportsSingleFileFiltering
-
Constructor Details
-
S3PersistentAcceptOnceFileListFilter
public S3PersistentAcceptOnceFileListFilter(org.springframework.integration.metadata.ConcurrentMetadataStore store, String prefix)
-
-
Method Details
-
modified
- Specified by:
modifiedin classorg.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<S3ObjectSummary>
-
fileName
- Specified by:
fileNamein classorg.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<S3ObjectSummary>
-
isDirectory
Always return false since no directory notion in S3.- Overrides:
isDirectoryin classorg.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<S3ObjectSummary>- Parameters:
file- theS3ObjectSummary- Returns:
- always false: S3 does not have a notion of directory
- Since:
- 2.5
-