public class S3StreamingMessageSource
extends org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<com.amazonaws.services.s3.model.S3ObjectSummary>
AbstractRemoteFileStreamingMessageSource implementation for the Amazon S3.| Constructor and Description |
|---|
S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<com.amazonaws.services.s3.model.S3ObjectSummary> template) |
S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<com.amazonaws.services.s3.model.S3ObjectSummary> template,
java.util.Comparator<org.springframework.integration.file.remote.AbstractFileInfo<com.amazonaws.services.s3.model.S3ObjectSummary>> comparator) |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.List<org.springframework.integration.file.remote.AbstractFileInfo<com.amazonaws.services.s3.model.S3ObjectSummary>> |
asFileInfoList(java.util.Collection<com.amazonaws.services.s3.model.S3ObjectSummary> collection) |
java.lang.String |
getComponentType() |
protected org.springframework.integration.file.remote.AbstractFileInfo<com.amazonaws.services.s3.model.S3ObjectSummary> |
poll() |
afterPropertiesSet, doInit, doReceive, doReceive, doSetFilter, getRemoteFileTemplate, remotePath, rollbackFromFileToListEnd, setFileInfoJson, setFilter, setRemoteDirectory, setRemoteDirectoryExpression, setRemoteFileSeparatorgetMaxFetchSize, setMaxFetchSizebuildMessage, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeevaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServiceclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<com.amazonaws.services.s3.model.S3ObjectSummary> template)
public S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<com.amazonaws.services.s3.model.S3ObjectSummary> template,
java.util.Comparator<org.springframework.integration.file.remote.AbstractFileInfo<com.amazonaws.services.s3.model.S3ObjectSummary>> comparator)
protected java.util.List<org.springframework.integration.file.remote.AbstractFileInfo<com.amazonaws.services.s3.model.S3ObjectSummary>> asFileInfoList(java.util.Collection<com.amazonaws.services.s3.model.S3ObjectSummary> collection)
asFileInfoList in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<com.amazonaws.services.s3.model.S3ObjectSummary>public java.lang.String getComponentType()
protected org.springframework.integration.file.remote.AbstractFileInfo<com.amazonaws.services.s3.model.S3ObjectSummary> poll()
poll in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<com.amazonaws.services.s3.model.S3ObjectSummary>