Class S3InboundFileSynchronizer
java.lang.Object
org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<S3ObjectSummary>
org.springframework.integration.aws.inbound.S3InboundFileSynchronizer
- All Implemented Interfaces:
Closeable,AutoCloseable,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.InitializingBean,org.springframework.integration.file.remote.synchronizer.InboundFileSynchronizer
public class S3InboundFileSynchronizer
extends org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<S3ObjectSummary>
An implementation of
AbstractInboundFileSynchronizer for Amazon S3.- Author:
- Artem Bilan
-
Field Summary
Fields inherited from class org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer
EXPRESSION_PARSER, logger -
Constructor Summary
ConstructorsConstructorDescriptionS3InboundFileSynchronizer(AmazonS3 amazonS3) S3InboundFileSynchronizer(org.springframework.integration.file.remote.session.SessionFactory<S3ObjectSummary> sessionFactory) Create a synchronizer with theSessionFactoryused to acquireSessioninstances. -
Method Summary
Modifier and TypeMethodDescriptionprotected booleancopyFileToLocalDirectory(String remoteDirectoryPath, org.springframework.expression.EvaluationContext localFileEvaluationContext, S3ObjectSummary remoteFile, File localDirectory, org.springframework.integration.file.remote.session.Session<S3ObjectSummary> session) protected StringgetFilename(S3ObjectSummary file) protected longgetModified(S3ObjectSummary file) protected booleanisFile(S3ObjectSummary file) protected Stringprotocol()Methods inherited from class org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer
afterPropertiesSet, close, doInit, doSetFilter, doSetRemoteDirectoryExpression, filterFiles, getComparator, getRemoteFileMetadata, getTemporaryFileSuffix, removeRemoteFileMetadata, rollbackFromFileToListEnd, setBeanFactory, setBeanName, setComparator, setDeleteRemoteFiles, setFilter, setLocalFilenameGeneratorExpression, setLocalFilenameGeneratorExpressionString, setMetadataStorePrefix, setPreserveTimestamp, setRemoteDirectory, setRemoteDirectoryExpression, setRemoteDirectoryExpressionString, setRemoteFileMetadataStore, setRemoteFileSeparator, setTemporaryFileSuffix, synchronizeToLocalDirectory, synchronizeToLocalDirectory
-
Constructor Details
-
S3InboundFileSynchronizer
public S3InboundFileSynchronizer() -
S3InboundFileSynchronizer
-
S3InboundFileSynchronizer
public S3InboundFileSynchronizer(org.springframework.integration.file.remote.session.SessionFactory<S3ObjectSummary> sessionFactory) Create a synchronizer with theSessionFactoryused to acquireSessioninstances.- Parameters:
sessionFactory- The session factory.
-
-
Method Details
-
isFile
- Specified by:
isFilein classorg.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<S3ObjectSummary>
-
getFilename
- Specified by:
getFilenamein classorg.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<S3ObjectSummary>
-
getModified
- Specified by:
getModifiedin classorg.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<S3ObjectSummary>
-
copyFileToLocalDirectory
protected boolean copyFileToLocalDirectory(String remoteDirectoryPath, @Nullable org.springframework.expression.EvaluationContext localFileEvaluationContext, S3ObjectSummary remoteFile, File localDirectory, org.springframework.integration.file.remote.session.Session<S3ObjectSummary> session) throws IOException - Overrides:
copyFileToLocalDirectoryin classorg.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<S3ObjectSummary>- Throws:
IOException
-
protocol
- Specified by:
protocolin classorg.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<S3ObjectSummary>
-