public class S3StreamingMessageSource extends org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>
AbstractRemoteFileStreamingMessageSource implementation for the Amazon S3.| Constructor and Description |
|---|
S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template) |
S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template,
java.util.Comparator<org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary>> comparator) |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.List<org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary>> |
asFileInfoList(java.util.Collection<S3ObjectSummary> collection) |
java.lang.String |
getComponentType() |
protected org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary> |
poll() |
afterPropertiesSet, doInit, doReceive, getRemoteFileTemplate, remotePath, setFilter, setRemoteDirectory, setRemoteDirectoryExpression, setRemoteFileSeparatorgetComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, isCountsEnabled, isLoggingEnabled, receive, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeevaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServicepublic S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template)
public S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template, java.util.Comparator<org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary>> comparator)
protected java.util.List<org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary>> asFileInfoList(java.util.Collection<S3ObjectSummary> collection)
asFileInfoList in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>public java.lang.String getComponentType()
protected org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary> poll()
poll in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>