feat: S3OutboundChannelAdapterParser for s3-outbound-channel-adapter

Author: boolivar

int-aws-support/src/main/java/org/springframework/integration/aws/config/xml/S3OutboundChannelAdapterParser.java

@@ -0,0 +1,24 @@
+package org.springframework.integration.aws.config.xml;
+
+import org.springframework.beans.factory.support.AbstractBeanDefinition;
+import org.springframework.beans.factory.xml.ParserContext;
+import org.springframework.expression.Expression;
+import org.springframework.integration.aws.outbound.S3MessageHandler;
+import org.springframework.integration.config.xml.AbstractOutboundChannelAdapterParser;
+import org.w3c.dom.Element;
+
+public class S3OutboundChannelAdapterParser extends AbstractOutboundChannelAdapterParser {
+
+    @Override
+    protected AbstractBeanDefinition parseConsumer(Element element, ParserContext parserContext) {
+        return XmlBeanDefinitionBuilder.newInstance(element, parserContext, S3MessageHandler.class)
+            .addExclusiveConstructorArgReference("s3", "transfer-manager")
+            .addExclusiveConstructorArgValue("bucket", "bucket-expression", String.class, Expression.class)
+            .setPropertyValueIfAttributeDefined("key-expression")
+            .setPropertyValueIfAttributeDefined("destination-bucket-expression")
+            .setPropertyValueIfAttributeDefined("destination-key-expression")
+            .setPropertyValueIfExclusiveAttributeDefined("command", "command-expression")
+            .setPropertyReferenceIfAttributeDefined("upload-metadata-provider")
+            .build();
+    }
+}

int-aws-support/src/main/java/org/springframework/integration/aws/config/xml/XmlBeanDefinitionBuilder.java

@@ -45,11 +45,33 @@ public XmlBeanDefinitionBuilder addConstructorArgReference(String attributeName)
         return this;
     }
 
+    public XmlBeanDefinitionBuilder addExclusiveConstructorArgReference(String attribute1, String attribute2) {
+        var value1 = element.getAttribute(attribute1);
+        var value2 = element.getAttribute(attribute2);
+        if (StringUtils.hasText(value1) == StringUtils.hasText(value2)) {
+            error(attribute1 + " or " + attribute2 + " required and mutually exclusive");
+        } else {
+            builder.addConstructorArgReference(StringUtils.hasText(value1) ? value1 : value2);
+        }
+        return this;
+    }
+
     public XmlBeanDefinitionBuilder addConstructorArgValue(String attributeName) {
         builder.addConstructorArgValue(new TypedStringValue(element.getAttribute(attributeName)));
         return this;
     }
 
+    public XmlBeanDefinitionBuilder addExclusiveConstructorArgValue(String attribute1, String attribute2, Class<?> type1, Class<?> type2) {
+        var value1 = element.getAttribute(attribute1);
+        var value2 = element.getAttribute(attribute2);
+        if (StringUtils.hasText(value1) == StringUtils.hasText(value2)) {
+            error(attribute1 + " or " + attribute2 + " required and mutually exclusive");
+        } else {
+            builder.addConstructorArgValue(StringUtils.hasText(value1) ? new TypedStringValue(value1, type1) : new TypedStringValue(value2, type2));
+        }
+        return this;
+    }
+
     public XmlBeanDefinitionBuilder setPropertyReference(String attributeName) {
         builder.addPropertyReference(attributeNameToPropertyName(attributeName), element.getAttribute(attributeName));
         return this;

int-aws-support/src/main/resources/org/springframework/integration/aws/config/xml/element-parser.mapping

@@ -1,4 +1,5 @@
 s3-inbound-channel-adapter: org.springframework.integration.aws.config.xml.S3InboundChannelAdapterParser
 s3-inbound-streaming-channel-adapter: org.springframework.integration.aws.config.xml.S3InboundStreamingChannelAdapterParser
+s3-outbound-channel-adapter: org.springframework.integration.aws.config.xml.S3OutboundChannelAdapterParser
 sqs-outbound-channel-adapter: org.springframework.integration.aws.config.xml.SqsOutboundChannelAdapterParser
 sqs-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.SqsMessageDrivenChannelAdapterParser