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<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 boolean |
isDirectory(S3ObjectSummary file) |
protected org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary> |
poll() |
doInit, doReceive, doSetFilter, getRemoteFileTemplate, isRunning, onInit, remotePath, rollbackFromFileToListEnd, setFileInfoJson, setFilter, setRemoteDirectory, setRemoteDirectoryExpression, setRemoteFileSeparator, start, stopdoReceive, getMaxFetchSize, setMaxFetchSizebuildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeafterPropertiesSet, evaluateExpression, 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<S3ObjectSummary> template)
public S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template, java.util.Comparator<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>protected boolean isDirectory(S3ObjectSummary file)
isDirectory in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>