feat: KinesisOutboundChannelAdapterParser

Author: boolivar

int-aws/src/main/java/org/springframework/integration/aws/config/xml/KinesisOutboundChannelAdapterParser.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.KinesisMessageHandler;
+import org.springframework.integration.config.xml.AbstractOutboundChannelAdapterParser;
+import org.w3c.dom.Element;
+
+public class KinesisOutboundChannelAdapterParser extends AbstractOutboundChannelAdapterParser {
+
+    @Override
+    protected AbstractBeanDefinition parseConsumer(Element element, ParserContext parserContext) {
+        return XmlBeanDefinitionBuilder.newInstance(element, parserContext, KinesisMessageHandler.class)
+            .addConstructorArgReference("kinesis-client")
+            .setPropertyIfAttributeDefined("async")
+            .setPropertyIfAttributeDefined("output-channel", "outputChannelName")
+            .setPropertyIfAttributeDefined("send-timeout")
+            .setPropertyOrExpressionStringIfAttributeDefined("stream")
+            .setPropertyOrExpressionStringIfAttributeDefined("partition-key")
+            .setPropertyOrExpressionStringIfAttributeDefined("explicit-hash-key")
+            .setPropertyIfAttributeDefined("sequence-number-expression", "sequenceNumberExpressionString")
+            .setPropertyReferenceIfAttributeDefined("embedded-headers-mapper")
+            .setPropertyReferenceIfAttributeDefined("message-converter")
+            .build();
+    }
+}

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

@@ -1,2 +1,3 @@
 kcl-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.KclMessageDrivenChannelAdapterParser
-kinesis-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.KinesisMessageDrivenChannelAdapterParser
+kinesis-message-driven-channel-adapter: org.springframework.integration.aws.config.xml.KinesisMessageDrivenChannelAdapterParser
+kinesis-outbound-channel-adapter: org.springframework.integration.aws.config.xml.KinesisOutboundChannelAdapterParser