feat: SpringIntegrationAwsNamespaceHandler parsers auto registration

Author: boolivar

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

@@ -0,0 +1,59 @@
+package org.springframework.integration.aws.config.xml;
+
+import org.springframework.beans.factory.xml.BeanDefinitionParser;
+import org.springframework.beans.factory.xml.NamespaceHandlerSupport;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.UncheckedIOException;
+
+public class SpringIntegrationAwsNamespaceHandler extends NamespaceHandlerSupport {
+
+    @Override
+    public void init() {
+        var classLoader = getClass().getClassLoader();
+        var packageName = getClass().getPackageName();
+        try (var in = classLoader.getResourceAsStream(packageName.replace('.', '/'))) {
+            new BufferedReader(new InputStreamReader(in)).lines()
+                .filter(name -> name.endsWith(".class"))
+                .map(className -> loadClass(classLoader, packageName + '.' + className.replace(".class", "")))
+                .filter(BeanDefinitionParser.class::isAssignableFrom)
+                .forEach(type -> registerBeanDefinitionParser(mapName(type), createParser(type)));
+        } catch (IOException e) {
+            throw new UncheckedIOException("Error reading classes for package " + packageName, e);
+        }
+    }
+
+    private String mapName(Class<?> type) {
+        var typeName = type.getSimpleName().replaceAll("Parser$", "");
+        StringBuilder sb = new StringBuilder();
+        sb.append(Character.toLowerCase(typeName.charAt(0)));
+        for (int i = 1; i < typeName.length(); ++i) {
+            var c = typeName.charAt(i);
+            if (Character.isUpperCase(c)) {
+                sb.append('-').append(Character.toLowerCase(c));
+            } else {
+                sb.append(c);
+            }
+        }
+        return sb.toString();
+    }
+
+
+    private Class<?> loadClass(ClassLoader classLoader, String name) {
+        try {
+            return classLoader.loadClass(name);
+        } catch (ClassNotFoundException e) {
+            throw new RuntimeException("Error load class " + name, e);
+        }
+    }
+
+    private BeanDefinitionParser createParser(Class<?> type) {
+        try {
+            return (BeanDefinitionParser) type.getConstructor().newInstance();
+        } catch (Exception e) {
+            throw new RuntimeException("Error instantiate parser of type " + type);
+        }
+    }
+}

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

@@ -0,0 +1,14 @@
+package org.springframework.integration.aws.config.xml;
+
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.beans.factory.xml.BeanDefinitionParser;
+import org.springframework.beans.factory.xml.ParserContext;
+import org.w3c.dom.Element;
+
+public class SqsOutboundChannelAdapterParser implements BeanDefinitionParser {
+
+    @Override
+    public BeanDefinition parse(Element element, ParserContext parserContext) {
+        return null;
+    }
+}

int-aws-support/src/main/resources/META-INF/spring.handlers

@@ -0,0 +1,2 @@
+http\://www.springframework.org/schema/integration/aws=org.springframework.integration.aws.config.xml.SpringIntegrationAwsNamespaceHandler
+https\://www.springframework.org/schema/integration/aws=org.springframework.integration.aws.config.xml.SpringIntegrationAwsNamespaceHandler

int-aws-support/src/main/resources/META-INF/spring.schemas

@@ -0,0 +1,2 @@
+http\://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd=org/springframework/schema/integration/aws/spring-integration-aws.xsd
+https\://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd=org/springframework/schema/integration/aws/spring-integration-aws.xsd