Enable auto-discovery of camel routes defined in a configured package. Added a Demo

MoquiConf.xml

@@ -2,6 +2,7 @@
 <!-- No copyright or license for configuration file, details here are not considered a creative work. -->
 <moqui-conf xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="http://moqui.org/xsd/moqui-conf-2.1.xsd">
 
+    <default-property name="org.moqui.camel.routes.package" value="org.moqui.camel.routes"/>
     <tools>
         <tool-factory class="org.moqui.impl.service.camel.CamelToolFactory" init-priority="20" disabled="false"/>
     </tools>

data/demoData.json

@@ -0,0 +1,5 @@
+{
+	"testInput": "foo bar",
+	"authUsername": "john.doe",
+	"authPassword": "moqui"
+}

src/main/groovy/org/moqui/camel/routes/MoquiDemoRoute.java

@@ -0,0 +1,39 @@
+/*
+ * This software is in the public domain under CC0 1.0 Universal plus a
+ * Grant of Patent License.
+ *
+ * To the extent possible under law, the author(s) have dedicated all
+ * copyright and related and neighboring rights to this software to the
+ * public domain worldwide. This software is distributed without any
+ * warranty.
+ *
+ * You should have received a copy of the CC0 Public Domain Dedication
+ * along with this software (see the LICENSE.md file). If not, see
+ * <http://creativecommons.org/publicdomain/zero/1.0/>.
+ */
+package org.moqui.camel.routes;
+
+import java.util.HashMap;
+import java.util.Map;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.builder.RouteBuilder;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+public class MoquiDemoRoute extends RouteBuilder {
+
+    @Override
+    public void configure() throws Exception {
+        from("file://runtime/component/moqui-camel/data?fileName=demoData.json&noop=true")
+                .convertBodyTo(String.class)
+                .process(new Processor() {
+                    @Override @SuppressWarnings("unchecked")
+                    public void process(Exchange exchange) throws Exception {
+                        String body = exchange.getIn().getBody(String.class);
+                        Map<String, Object> bodyMap = new ObjectMapper().readValue(body, HashMap.class);
+                        exchange.getOut().setBody(bodyMap, Map.class);
+                    }
+                })
+                .to("moquiservice://moqui.example.ExampleServices.targetCamelExample");
+    }
+}

src/main/groovy/org/moqui/impl/service/camel/CamelToolFactory.groovy

@@ -16,6 +16,9 @@ package org.moqui.impl.service.camel
 import groovy.transform.CompileStatic
 import org.apache.camel.CamelContext
 import org.apache.camel.impl.DefaultCamelContext
+import org.apache.camel.builder.RouteBuilder
+import org.apache.camel.impl.DefaultPackageScanClassResolver
+import org.apache.camel.spi.PackageScanClassResolver
 import org.moqui.context.ExecutionContextFactory
 import org.moqui.context.ToolFactory
 import org.slf4j.Logger
@@ -44,6 +47,7 @@ class CamelToolFactory implements ToolFactory<CamelContext> {
         logger.info("Starting Camel")
         moquiServiceComponent = new MoquiServiceComponent(this)
         camelContext.addComponent("moquiservice", moquiServiceComponent)
+        if(System.getProperty("org.moqui.camel.routes.package"))loadRoutes()
         camelContext.start()
     }
     @Override
@@ -69,4 +73,45 @@ class CamelToolFactory implements ToolFactory<CamelContext> {
     MoquiServiceComponent getMoquiServiceComponent() { return moquiServiceComponent }
     void registerCamelConsumer(String uri, MoquiServiceConsumer consumer) { camelConsumerByUriMap.put(uri, consumer) }
     MoquiServiceConsumer getCamelConsumer(String uri) { return camelConsumerByUriMap.get(uri) }
+
+
+    /**
+     * Auto load camel routes
+     */
+    private void loadRoutes(){
+        logger.info("Loading routes...")
+        PackageScanClassResolver packageResolver = new DefaultPackageScanClassResolver()
+        Set<Class<?>> routesClassesSet = packageResolver.findImplementations(RouteBuilder.class, System.getProperty("org.moqui.camel.routes.package"));
+        routesClassesSet.each{key ->
+            RouteBuilder routeBuilder = createRoutes(key.getName());
+            addRoutesToContext(routeBuilder);
+        }
+    }
+
+    /**
+     * Loads {@code routeBuilderCls} to add into CamelContext
+     * @param routeBuilderCls
+     * @return
+     */
+    private RouteBuilder createRoutes(String routeBuilderCls) {
+        ClassLoader loader = Thread.currentThread().getContextClassLoader();
+        try {
+            Class<?> c = loader.loadClass(routeBuilderCls);
+            return (RouteBuilder) c.newInstance();
+        } catch (Exception e) {
+            logger.error("Error in loading routeBuilderCls "+routeBuilderCls, e)
+        }
+    }
+
+    /**
+     * Adds {@code routeBuilder} to the CamelContext
+     * @param routeBuilder
+     */
+    private void addRoutesToContext(RouteBuilder routeBuilder) {
+        try {
+            camelContext.addRoutes(routeBuilder);
+        } catch (Exception e) {
+            logger.error("Cannot add routes to : " + routeBuilder, e);
+        }
+    }
 }