feat: SqsOutboundChannelAdapterParser

Author: boolivar

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

@@ -0,0 +1,26 @@
+package org.springframework.integration.aws.config.xml;
+
+import org.springframework.beans.factory.support.AbstractBeanDefinition;
+import org.springframework.beans.factory.xml.ParserContext;
+import org.springframework.integration.aws.outbound.SqsMessageHandler;
+import org.springframework.integration.config.xml.AbstractOutboundChannelAdapterParser;
+import org.w3c.dom.Element;
+
+public class SqsOutboundChannelAdapterParser extends AbstractOutboundChannelAdapterParser {
+
+    @Override
+    protected AbstractBeanDefinition parseConsumer(Element element, ParserContext parserContext) {
+        return XmlBeanDefinitionBuilder.newInstance(element, parserContext, SqsMessageHandler.class)
+            .addConstructorArgReference("sqs")
+            .setPropertyOrExpressionStringIfAttributeDefined("queue")
+            .setPropertyOrExpressionStringIfAttributeDefined("delay")
+            .setPropertyOrExpressionStringIfAttributeDefined("message-group-id")
+            .setPropertyOrExpressionStringIfAttributeDefined("message-deduplication-id")
+            .setPropertyOrExpressionStringIfAttributeDefined("send-timeout")
+            .setPropertyIfAttributeDefined("async")
+            .setPropertyIfAttributeDefined("queue-not-found-strategy")
+            .setPropertyIfAttributeDefined("output-channel", "outputChannelName")
+            .setPropertyReferenceIfAttributeDefined("message-converter")
+            .build();
+    }
+}

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

@@ -2,4 +2,5 @@ kcl-message-driven-channel-adapter: org.springframework.integration.aws.config.x
 kinesis-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.KinesisMessageDrivenChannelAdapterParser
 kinesis-outbound-channel-adapter: org.springframework.integration.aws.config.xml.KinesisOutboundChannelAdapterParser
 kpl-outbound-channel-adapter: org.springframework.integration.aws.config.xml.KplOutboundChannelAdapterParser
+sqs-outbound-channel-adapter: org.springframework.integration.aws.config.xml.SqsOutboundChannelAdapterParser
 sqs-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.SqsMessageDrivenChannelAdapterParser