在运行时从文件加载 Apache Camel 路由

Question

我正在尝试在运行时从文件加载 Apache Camel 路由。这意味着

我的“route.yaml”文件如下。

- route:
    from: "timer:yaml?period=3s"
    steps:
      - set-body:
          simple: "Timer fired ${header.CamelTimerCounter} times"
      - to:
          uri: "log:yaml"

我发现过去可以执行以下操作来加载路线 xml 文件，但现在不能这样做。例如，我在无法启动从外部 XML 加载的 Camel 路由中看到 loadRoutesDefinition

InputStream routesXml = new ByteArrayInputStream(routePropertyValue.toString().getBytes());
RoutesDefinition loadedRoutes = camelContext.loadRoutesDefinition(routesXml);
camelContext.addRouteDefinitions(loadedRoutes.getRoutes());

如何使用当前的 Apache Camel 做到这一点？

Answer 1

我能够将其从 yaml 字符串加载到 RouteBuilder 中

package org.acme;

import org.apache.camel.CamelContext;
import org.apache.camel.ExtendedCamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.spi.Resource;
import org.apache.camel.spi.RoutesLoader;
import org.apache.camel.support.ResourceHelper;

public class MyRouteBuilder extends RouteBuilder {

    @Override
    public void configure() {
        CamelContext context = getContext();
        String myRoute = "- route:\n" +
                "    from: \"timer:yaml?period=3s\"\n" +
                "    steps:\n" +
                "      - set-body:\n" +
                "          simple: \"Timer fired ${header.CamelTimerCounter} times\"\n" +
                "      - to:\n" +
                "          uri: \"log:yaml\"\n" +
                "\n";
        try {
            ExtendedCamelContext extendedCamelContext = context.adapt(ExtendedCamelContext.class);
            RoutesLoader loader = extendedCamelContext.getRoutesLoader();
            Resource resource = ResourceHelper.fromString("any.yaml", myRoute);
            loader.loadRoutes(resource);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}