如何在quarkus Camel中使用Apache Camel“direct”

Question

我添加了io。quarkus:quarkus骆驼核心到我的应用程序，但直接启动在本机映像中不起作用。如果我在JVM中运行quarkus，那么它可以工作。

Github中有一些项目(https://github.com/apache/camel-quarkus/tree/master/extensions/direct)这在某种程度上表明，未来有一个扩展计划，但它没有得到官方支持。

如何使其以最小的工作量运行，例如仅为direct创建自己的扩展项目。如果我将现有项目添加到Maven pom中，我会遇到不同Maven坐标的问题，最终本地构建告诉我存在重复的项目。

什么是让骆驼的“直接”声明在夸克斯运行的好方法？

顺便说一下，原生建筑工程，即。我得到一个可执行文件，但是直接语句的注入不起作用：

“org.apache.camel.ResolveEndpointFailedException:未能解析终结点：direct://init原因：未找到方案为“直接”的组件

来源： RESTendpoint：

@Path("/hello")
public class GreetingResource {

    @GET
    @Produces(MediaType.TEXT_PLAIN)
    public String hello() {
        ExchangeBuilder exchangeBuilder = new ExchangeBuilder(context);
        Exchange out = template.send("direct:init", exchangeBuilder.build());

        return out.getOut().toString();
    }

CamelRouteBuilder：

public class CamelSyncRouteBuilder extends RouteBuilder {

    static final String HTTP_ROUTE_ID = "http:camel";
    static long[] times = new long[1];

    @Override
    public void configure() throws Exception {
        from("direct:init").routeId(HTTP_ROUTE_ID)
                .setHeader(MyOrderService.class.getName(), MyOrderService::new)
                .setHeader(Filler.class.getName(), Filler::new).process(fill(Filler.class.getName(), "fill"))
                .split(body().tokenize("@"), CamelSyncRouteBuilder.this::aggregate)
                .process(stateless(MyOrderService.class.getName(), "handleOrder")).end().to("log:foo?level=OFF");
    }

波姆。xml:

<?xml version="1.0"?>
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.sap.it.graal</groupId>
  <artifactId>getting-started</artifactId>
  <version>1.0-SNAPSHOT</version>
  <properties>
    <surefire-plugin.version>2.22.0</surefire-plugin.version>
    <maven.compiler.target>1.8</maven.compiler.target>
    <maven.compiler.source>1.8</maven.compiler.source>
    <quarkus.version>0.19.1</quarkus.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  </properties>
  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>io.quarkus</groupId>
        <artifactId>quarkus-bom</artifactId>
        <version>${quarkus.version}</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>
  <dependencies>
    <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-resteasy</artifactId>
    </dependency>
    <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-junit5</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>io.rest-assured</groupId>
      <artifactId>rest-assured</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-camel-core</artifactId>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>io.quarkus</groupId>
        <artifactId>quarkus-maven-plugin</artifactId>
        <version>${quarkus.version}</version>
        <executions>
          <execution>
            <goals>
              <goal>build</goal>
            </goals>
          </execution>
        </executions>
      </plugin>
      <plugin>
        <artifactId>maven-surefire-plugin</artifactId>
        <version>${surefire-plugin.version}</version>
        <configuration>
          <systemProperties>
            <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager>
          </systemProperties>
        </configuration>
      </plugin>
    </plugins>
  </build>
  <profiles>
    <profile>
      <id>native</id>
      <activation>
        <property>
          <name>native</name>
        </property>
      </activation>
      <build>
        <plugins>     
          <plugin>
            <groupId>io.quarkus</groupId>
            <artifactId>quarkus-maven-plugin</artifactId>
            <version>${quarkus.version}</version>
            <executions>
              <execution>
                <goals>
                  <goal>native-image</goal>
                </goals>
                <configuration>
                  <enableHttpUrlHandler>true</enableHttpUrlHandler>
                </configuration>
              </execution>
            </executions>
          </plugin>
          <plugin>
            <artifactId>maven-failsafe-plugin</artifactId>
            <version>${surefire-plugin.version}</version>
            <executions>
              <execution>
                <goals>
                  <goal>integration-test</goal>
                  <goal>verify</goal>
                </goals>
                <configuration>
                  <systemProperties>
                    <native.image.path>${project.build.directory}/${project.build.finalName}-runner</native.image.path>
                  </systemProperties>
                </configuration>
              </execution>
            </executions>
          </plugin>
        </plugins>
      </build>
    </profile>
  </profiles>
</project>

Answer 1

我也面临着同样的问题，因为我没有学到骆驼是如何工作的。正如日志中所说，您没有提供“直接”URI的组件。所以你必须添加那个组件。骆驼Quarkus扩展中有一个：

<dependency>
  <groupId>org.apache.camel.quarkus</groupId>
  <artifactId>camel-quarkus-direct</artifactId>
</dependency>

Answer 2

即使没有专用扩展，direct组件也应该开箱即用，例如，它用于为jdbc组件创建集成测试(https://github.com/apache/camel-quarkus/tree/master/integration-tests/jdbc).

你能分享更多关于你的项目和设置的信息吗？