Skip to content

Commit e1c543c

Browse files
committed
feat: S3InboundStreamingChannelAdapterParser to parse s3-inbound-streaming-channel-adapter
1 parent d340201 commit e1c543c

File tree

2 files changed

+37
-0
lines changed

2 files changed

+37
-0
lines changed
Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
package org.springframework.integration.aws.config.xml;
2+
3+
import org.springframework.integration.aws.inbound.S3StreamingMessageSource;
4+
import org.springframework.integration.aws.support.S3RemoteFileTemplate;
5+
import org.springframework.integration.aws.support.filters.S3PersistentAcceptOnceFileListFilter;
6+
import org.springframework.integration.aws.support.filters.S3RegexPatternFileListFilter;
7+
import org.springframework.integration.aws.support.filters.S3SimplePatternFileListFilter;
8+
import org.springframework.integration.file.config.AbstractRemoteFileStreamingInboundChannelAdapterParser;
9+
10+
public class S3InboundStreamingChannelAdapterParser extends AbstractRemoteFileStreamingInboundChannelAdapterParser {
11+
12+
@Override
13+
protected Class<S3StreamingMessageSource> getMessageSourceClass() {
14+
return S3StreamingMessageSource.class;
15+
}
16+
17+
@Override
18+
protected Class<S3RemoteFileTemplate> getTemplateClass() {
19+
return S3RemoteFileTemplate.class;
20+
}
21+
22+
@Override
23+
protected Class<S3SimplePatternFileListFilter> getSimplePatternFileListFilterClass() {
24+
return S3SimplePatternFileListFilter.class;
25+
}
26+
27+
@Override
28+
protected Class<S3RegexPatternFileListFilter> getRegexPatternFileListFilterClass() {
29+
return S3RegexPatternFileListFilter.class;
30+
}
31+
32+
@Override
33+
protected Class<S3PersistentAcceptOnceFileListFilter> getPersistentAcceptOnceFileListFilterClass() {
34+
return S3PersistentAcceptOnceFileListFilter.class;
35+
}
36+
}
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
s3-inbound-channel-adapter: org.springframework.integration.aws.config.xml.S3InboundChannelAdapterParser
2+
s3-inbound-streaming-channel-adapter: org.springframework.integration.aws.config.xml.S3InboundStreamingChannelAdapterParser
23
sqs-outbound-channel-adapter: org.springframework.integration.aws.config.xml.SqsOutboundChannelAdapterParser
34
sqs-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.SqsMessageDrivenChannelAdapterParser

0 commit comments

Comments
 (0)