Class S3StreamingMessageSource
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<T>
org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource<InputStream>
org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>
org.springframework.integration.aws.inbound.S3StreamingMessageSource
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.integration.core.MessageSource<InputStream>,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationInboundManagement,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.MessageSourceManagement
public class S3StreamingMessageSource
extends org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>
A
AbstractRemoteFileStreamingMessageSource implementation for the Amazon S3.- Since:
- 1.1
- Author:
- Christian Tzolov, Artem Bilan
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides -
Field Summary
Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME -
Constructor Summary
ConstructorsConstructorDescriptionS3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template) S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template, Comparator<S3ObjectSummary> comparator) -
Method Summary
Modifier and TypeMethodDescriptionprotected List<org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary>>asFileInfoList(Collection<S3ObjectSummary> collection) protected booleanisDirectory(S3ObjectSummary file) protected org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary>poll()Methods inherited from class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource
doInit, doReceive, doSetFilter, getRemoteFileTemplate, isRunning, onInit, remotePath, rollbackFromFileToListEnd, setFileInfoJson, setFilter, setRemoteDirectory, setRemoteDirectoryExpression, setRemoteFileSeparator, start, stopMethods inherited from class org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource
doReceive, getMaxFetchSize, setMaxFetchSizeMethods inherited from class org.springframework.integration.endpoint.AbstractMessageSource
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeMethods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServiceMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAsMethods inherited from interface org.springframework.integration.core.MessageSource
getIntegrationPatternType
-
Constructor Details
-
S3StreamingMessageSource
public S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template) -
S3StreamingMessageSource
public S3StreamingMessageSource(org.springframework.integration.file.remote.RemoteFileTemplate<S3ObjectSummary> template, Comparator<S3ObjectSummary> comparator)
-
-
Method Details
-
asFileInfoList
protected List<org.springframework.integration.file.remote.AbstractFileInfo<S3ObjectSummary>> asFileInfoList(Collection<S3ObjectSummary> collection) - Specified by:
asFileInfoListin classorg.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>
-
getComponentType
-
poll
- Overrides:
pollin classorg.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>
-
isDirectory
- Specified by:
isDirectoryin classorg.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<S3ObjectSummary>
-