apache骆驼java中的NoSuchMethodError

Question

我运行了以下代码：

package com.dinesh.example4;

import javax.jms.ConnectionFactory;
//import org.apache.camel.support.HeaderFilterStrategyComponent;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.camel.CamelContext;
import org.apache.camel.Component;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.JmsComponent;
import org.apache.camel.impl.DefaultCamelContext;
//import org.apache.camel.impl.*;

public class FileToActiveMQ {
    
    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        context.addComponent("jms",JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
        context.addRoutes(new RouteBuilder() {
            
            @Override
            public void configure() throws Exception {
              from("file:input_box?noop=true")
                .to("activemq:queue:my_queue");
                }
        });
        while(true)
        context.start();
        }
}

用于将 input_box 文件夹中的数据转换为 activemq。

我收到以下错误：

Exception in thread "main" java.lang.NoSuchMethodError: org.apache.camel.impl.HeaderFilterStrategyComponent.<init>(Ljava/lang/Class;)V
    at org.apache.camel.component.jms.JmsComponent.<init>(JmsComponent.java:71)
    at org.apache.camel.component.jms.JmsComponent.<init>(JmsComponent.java:87)
    at org.apache.camel.component.jms.JmsComponent.jmsComponent(JmsComponent.java:102)
    at org.apache.camel.component.jms.JmsComponent.jmsComponentAutoAcknowledge(JmsComponent.java:127)
    at com.dinesh.example4.FileToActiveMQ.main(FileToActiveMQ.java:18)

上面代码的第 18 行： context.addRoutes(new RouteBuilder() {

Pom.xml：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.dinesh</groupId>
  <artifactId>camel-application1</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <dependencies>
  
  <!-- https://mvnrepository.com/artifact/org.apache.camel/camel-core -->
<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-core</artifactId>
    <version>2.14.4</version>
</dependency>

 <dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-jms</artifactId>
    <version>2.24.0</version>
</dependency>
<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-activemq</artifactId>
    <version>3.0.0</version>
</dependency>
  
  </dependencies>
</project>

请帮忙。

Answer 1

根据您的 POM，您可以混合使用 3 个不同的 Camel 版本：2.14.4、2.24.0 和 3.0.0。

您必须对所有 Camel 组件使用相同的版本，正如 @claus-ibsen 已经评论的那样。

例如像下面的例子那样做（使用框架版本的属性并在其所有依赖项中使用它）。

但是，正如 Sneharghya 已经回答的那样，Camel 2.x 没有 camel-activemq，而是可以使用 ActiveMQ 的依赖项 activemq-camel。

因此，POM 应该如下所示。但我认为 Camel 版本可能会有所不同。

<properties>
    <amq.version>5.15.4</amq.version>     
    <camel.version>2.19.5</camel.version> 
</properties>

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-core</artifactId>
    <version>${camel.version}</version>
</dependency>
 <dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-jms</artifactId>
    <version>${camel.version}</version>
</dependency>
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-camel</artifactId>
    <version>${amq.version}</version>
</dependency>

您也可以使用Maven dependencyManagement。

Answer 2

1.更新课程 有两个问题。

• 您在一个名称jms 中注册您的组件并将消​​息发送到不同的组件activemq。它们应该相同。
• 您正在执行 while 循环，而不是 while 循环多次启动上下文。

public class FileToActiveMQ {

  public static void main(String[] args) throws Exception {
    CamelContext context = new DefaultCamelContext();
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
    context.addComponent("activemq", 
          JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
    context.addRoutes(new RouteBuilder() {
      @Override
      public void configure() throws Exception {

        from("file:input_box?noop=true")
        .to("activemq:queue:my_queue");
      }
    });
   context.start();
   while(true) {
     Thread.sleep(10000);
   }

  }
}

2。替换pom中的依赖如下：

<dependencies>
    <dependency>
      <groupId>org.apache.camel</groupId>
      <artifactId>camel-core</artifactId>
      <version>2.25.1</version>
    </dependency>
    <dependency>
      <groupId>org.apache.camel</groupId>
      <artifactId>camel-jms</artifactId>
      <version>2.25.1</version>
    </dependency>

    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-client</artifactId>
      <version>5.15.7</version>
    </dependency>
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-camel</artifactId>
      <version>5.15.7</version>
    </dependency>
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-pool</artifactId>
      <version>5.15.7</version>
    </dependency>

  </dependencies>

Answer 3

camel-activemq 不适用于 3.0 之前的版本。 如果您想继续使用 camel 2.24.3，请从您的 pom 文件中删除 camel-activemq 依赖项并添加

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