Skip to content

Commit 7b0d715

Browse files
committed
feat: S3InboundChannelAdapterParser to parse s3-inbound-channel-adapter
1 parent df149c3 commit 7b0d715

File tree

3 files changed

+39
-0
lines changed

3 files changed

+39
-0
lines changed

int-aws-support/build.gradle

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,4 +7,6 @@ dependencies {
77
implementation "org.springframework.integration:spring-integration-aws"
88

99
compileOnly "io.awspring.cloud:spring-cloud-aws-sqs"
10+
compileOnly "io.awspring.cloud:spring-cloud-aws-s3"
11+
compileOnly "org.springframework.integration:spring-integration-file"
1012
}
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.S3InboundFileSynchronizer;
4+
import org.springframework.integration.aws.inbound.S3InboundFileSynchronizingMessageSource;
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.AbstractRemoteFileInboundChannelAdapterParser;
9+
10+
public class S3InboundChannelAdapterParser extends AbstractRemoteFileInboundChannelAdapterParser {
11+
12+
@Override
13+
protected String getMessageSourceClassname() {
14+
return S3InboundFileSynchronizingMessageSource.class.getName();
15+
}
16+
17+
@Override
18+
protected Class<S3InboundFileSynchronizer> getInboundFileSynchronizerClass() {
19+
return S3InboundFileSynchronizer.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,2 +1,3 @@
1+
s3-inbound-channel-adapter: org.springframework.integration.aws.config.xml.S3InboundChannelAdapterParser
12
sqs-outbound-channel-adapter: org.springframework.integration.aws.config.xml.SqsOutboundChannelAdapterParser
23
sqs-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.SqsMessageDrivenChannelAdapterParser

0 commit comments

Comments
 (0)