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, setRemoteFileSeparator
getMaxFetchSize, setMaxFetchSize
buildMessage, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public 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>