feat: KplOutboundChannelAdapterParser

Author: boolivar

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

@@ -0,0 +1,39 @@
+package org.springframework.integration.aws.config.xml;
+
+import org.springframework.beans.factory.support.AbstractBeanDefinition;
+import org.springframework.beans.factory.support.BeanDefinitionBuilder;
+import org.springframework.beans.factory.xml.ParserContext;
+import org.springframework.integration.aws.outbound.KplMessageHandler;
+import org.springframework.integration.config.xml.AbstractOutboundChannelAdapterParser;
+import org.w3c.dom.Element;
+
+import java.time.Duration;
+
+public class KplOutboundChannelAdapterParser extends AbstractOutboundChannelAdapterParser {
+
+    @Override
+    protected AbstractBeanDefinition parseConsumer(Element element, ParserContext parserContext) {
+        return XmlBeanDefinitionBuilder.newInstance(element, parserContext, KplMessageHandler.class)
+            .addConstructorArgReference("kinesis-producer")
+            .setPropertyIfAttributeDefined("async")
+            .setPropertyIfAttributeDefined("output-channel", "outputChannelName")
+            .setPropertyIfAttributeDefined("send-timeout")
+            .setPropertyOrExpressionStringIfAttributeDefined("stream")
+            .setPropertyOrExpressionStringIfAttributeDefined("partition-key")
+            .setPropertyOrExpressionStringIfAttributeDefined("explicit-hash-key")
+            .setPropertyIfAttributeDefined("sequence-number-expression", "sequenceNumberExpressionString")
+            .setPropertyIfAttributeDefined("glue-schema-expression", "glueSchemaExpressionString")
+            .setPropertyIfAttributeDefined("flush-duration", "flushDuration", this::duration)
+            .setPropertyReferenceIfAttributeDefined("embedded-headers-mapper")
+            .setPropertyReferenceIfAttributeDefined("message-converter")
+            .build();
+    }
+
+    private AbstractBeanDefinition duration(String millis) {
+        return BeanDefinitionBuilder.genericBeanDefinition(Duration.class)
+            .addConstructorArgValue(millis)
+            .setFactoryMethod("ofMillis")
+            .applyCustomizers(def -> def.setAutowireCandidate(false))
+            .getBeanDefinition();
+    }
+}

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

@@ -1,3 +1,4 @@
 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-outbound-channel-adapter: org.springframework.integration.aws.config.xml.KinesisOutboundChannelAdapterParser
+kinesis-outbound-channel-adapter: org.springframework.integration.aws.config.xml.KinesisOutboundChannelAdapterParser
+kpl-outbound-channel-adapter: org.springframework.integration.aws.config.xml.KplOutboundChannelAdapterParser