ServiceMix (FuseESB) - 无法使用 AggregationStrategy 部署服务单元

Question

我正在尝试将非常简单的 ESB 应用程序部署到 Apache ServiceMix (Fuse ESB)，并且所有工作都正常，直到我尝试使用“AggregationStrategy”接口。我正在使用 EIP 和聚合器模式构建概念验证，但由于 NoClassDefFound 错误而无法部署我的工件。看起来像一个典型的类加载问题，但我不知道如何解决它。我尝试了两种方法：添加和删除对我的服务单元（servicemix-camel 类型）的camel-core 依赖项。

该应用程序的基础可以在此处找到。我已将路由定义修改为以下内容：

public void configure() {
        from("activemq:test2").split(xpath("/notes/note")).parallelProcessing().process(new NoteProcessor()).to("activemq:test3");

        from("activemq:test3").aggregate(header("id"), new MyAggregationStrategy()).completionTimeout(3000).to("activemq:test");
    }

我的自定义 AggregationStrategy 如下所示：

package com.softwarepassion.tutorial.camel;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.processor.aggregate.AggregationStrategy;

public class MyAggregationStrategy implements AggregationStrategy {

    public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
        Message newIn = newExchange.getIn();
        String oldBody = oldExchange.getIn().getBody(String.class);
        String newBody = newIn.getBody(String.class);
        newIn.setBody(oldBody + newBody);
        return newExchange;
    }
}

我在普通 ServiceMix 以及 FuseESB 上收到以下错误：

07:50:49,625 |错误|使用-01-11/部署 |默认组件
| ？ ？ | 151-servicemix-通用- 2011.02.1.fuse-02-11 |创建名称为“template”的 bean 时出错：bean 初始化失败；嵌套异常是 org.springframework.beans.factory.BeanCreationException：错误 创建名称为“camel”的 bean：调用 init 方法失败； 嵌套异常是 org.springframework.beans.factory.BeanCreationException：错误 创建带有名称的bean “com.softwarepassion.tutorial.camel.MyRouteBuilder”：解析 bean 类上声明的构造函数 来自 ClassLoader 的 [com.softwarepassion.tutorial.camel.MyRouteBuilder] [[org.apache.xbean.classloader.JarFileClassLoader： 名称=org.apache.xbean.spring.context.FileSystemXmlApplicationContext@1c4d3b6 urls=[文件:/home/kris/apache-servicemix-4.4.1-fuse-01-11/data/jbi/tutorial-camel-sa/sus/tutorial-camel-su/] 父母=[[org.apache.xbean.classloader.JarFileClassLoader: 名称=SU 父类加载器 urls=[] 父母=[231.0, [camel-spring] 的 BundleDelegatingClassLoader (org.apache.camel.camel-spring)]，BundleDelegatingClassLoader [camel-cxf (org.apache.camel.camel-cxf)]，BundleDelegatingClassLoader 对于 [camel-cxf-transport (org.apache.camel.camel-cxf-transport)]]]]]] 失败的;嵌套异常是java.lang.NoClassDefFoundError： org/apache/camel/processor/aggregate/AggregationStrategy 07:50:49,627 |错误|使用-01-11/部署 |服务组件安装程序 | ？
？ | 147 - org.apache.servicemix.jbi.deployer - 1.5.1.fuse-01-11 | 部署 SU 教程-camel-su 时出错

Answer 1

不要使用 JBI，它是遗留的/已死的。
http://gnodet.blogspot.com/2010/12/thoughts-about -servicemix.html

使用 Camel 原型创建要部署在 ServiceMix 中的新 OSGi 项目。原型列表在这里
http://camel.apache.org/camel-maven-archetypes.html

例如camel-archetype-spring-dm或camel-archetype-blueprint

Answer 2

对于任何寻找上述问题解决方案的人，我终于找到了 这里，我应该切换到 OSGI 类型的部署。您可以在 FuseESB 安装根目录的“examples”目录中找到工作的camel-osgi 示例项目。