Apache Camel 上下文启动失败

Question

我对 Spring Boot、Apache Camel 和 ActiveMQ 代理还很陌生。我正在尝试创建一个应用程序，它将向我在本地托管的队列发送消息，该队列使用 Camel 进行路由。

POM:

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-core</artifactId>
    <version>2.22.0</version>
</dependency>

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-activemq</artifactId>
    <version>3.2.0</version>
</dependency>

MsgRouteBuilder:

public void configure() throws Exception {
    from("direct:firstRoute")
    .setBody(constant("Hello"))
    .to("activemq:queue:myQueue");
}

application.yaml:

activemq:
    broker-url: tcp://localhost:61616
    user: meAd
    password: meAd

MainApp.java:

package me.ad.myCamel;

import org.apache.camel.CamelContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.EnableAspectJAutoProxy;

import me.ad.myCamel.router.MessageRouteBuilder;

@SpringBootApplication
@EnableAutoConfiguration(exclude={DataSourceAutoConfiguration.class})
@EnableAspectJAutoProxy(proxyTargetClass = true)
@EnableCaching
public class MeAdApp implements CommandLineRunner {

  private static final Logger LOG = LoggerFactory.getLogger(MeAdApp.class);

  public static void main(String[] args) {
    try {
      SpringApplication.run(MeAdApp.class, args);
    } catch (Exception ex) {
      LOG.error(ex.getMessage(), ex);
    }
  }

  @Override
  public void run(String... args) throws Exception {
    LOG.info("Starting MeAdApp...");
  }  
}

MyController.java :

@GetMapping(value = "/routing")
public boolean sendToMyQueue() {
    sendMyInfo.startRouting();
    return true;
}

SendMyInfo.java :

MsgRouteBuilder routeBuilder = new MsgRouteBuilder();
CamelContext ctx = new DefaultCamelContext();


public void startRouting(){

    try {
        ctx.addRoutes(routeBuilder);
        ctx.start();
        Thread.sleep(5 * 60 * 1000);
        ctx.stop();
    }
    catch (Exception e) {
        e.printStackTrace();
    }

}

所以，每当我调用我的休息终点：/routing，我得到错误：

java.lang.NoSuchMethodError: org.apache.camel.RuntimeCamelException.wrapRuntimeException(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;`

任何人都可以指出我为什么会收到此错误的正确方向吗？非常感谢任何帮助。

Answer 1

您需要拥有相同版本的组件。如果您使用 3.2.0 的 camel-core，请使用 camel-activemq 3.2.0。而且，由于您使用的是 spring-boot，因此您可以使用启动器依赖项。只需添加这些即可。

<dependency>
    <groupId>org.apache.camel.springboot</groupId>
    <artifactId>camel-spring-boot-starter</artifactId>
    <version>3.2.0</version>
</dependency>
<dependency>
    <groupId>org.apache.camel.springboot</groupId>
    <artifactId>camel-activemq-starter</artifactId>
    <version>3.2.0</version>
</dependency>

Apache Camel 上下文启动失败

Apache Camel Context start failure

java

activemq

apache-camel

spring-boot