问题标签 [apache-camel]

我正在学习 ActiveMQ 和 Camel，目标是创建一个像这样工作的小原型系统：

_{（来源：paulstovell.com）}

（大的）

在 Orders 系统中下订单时，会向任何订阅者（发布/订阅系统）发送一条消息，他们可以在处理订单中发挥作用。Orders、Shipping和Invoicing应用程序都有自己的 ActiveMQ 安装，因此如果三个系统中的任何一个系统脱机，其他系统都可以继续运行。有些东西负责在 ActiveMQ 安装之间移动消息。

如果它们在同一个 ActiveMQ 实例上，让 Apache Camel 通过路由将消息从一个队列移动到另一个队列非常容易。所以这适用于管理订阅队列。

下一个挑战是将消息从一个 ActiveMQ 实例推送到另一个实例，这就是我不确定接下来要看什么的地方。

1. Camel 可以在不同的 ActiveMQ 安装之间路由吗？（如果它们在不同的机器上，我无法弄清楚 JMI 端点 URI 会是什么）。
2. 我了解 ActiveMQ 具有存储和转发功能。这是我用来在订单和运输/发票之间移动消息的方法吗？
3. 或者这就是Apache ServiceMix想要解决的问题？

如何使用 Apache Camel HTTP 组件进行多部分文件上传？

我一直在尝试添加自己的性能计数器，但我无法将此性能计数器用于我的路线。

谁能告诉我如何使用自定义性能计数器而不是 ManagedPerformanceCounter？

谢谢你。

我正在开发一个应用程序用户可以创建/删除队列的应用程序。此外，他将能够将消息从 1 个队列移动到另一个队列，删除消息，根据某些过滤器重新排列队列中的消息。

一种可能的设计是将activemq 用于队列，将apache camel 用于与Grails 集成的各种其他操作。但我不确定 ActiveMQ 是否允许在运行时创建/删除队列。
这是实施此类系统的好选择吗？

我有一个 ActiveMq 主题，我希望对其进行转换并与外部代理共享。目前我有以下执行转换：

然而，这只是将消息发送到当前的代理网络。我只想将NewTopic消息传递给外部代理。我不想使用<networkConnector .. >加入外部代理，因为只有这个主题应该发送给外部代理而不是其他代理。

有没有一种简单的方法可以将消息路由到外部代理？

非常感谢。

更新

上述方法还有一个缺点是原始主题的订阅者不再收到消息，有没有办法在不丢失原始主题的情况下路由到另一个目的地？

我有一个非常简单的骆驼路线。它从作为 Web 服务公开的 CXF 端点开始。然后我想将它转换为 xml 并在 bean 上调用一个方法。

目前我在 Web 服务调用后得到一个 CXF 特定对象。如何从 CXF MessageList 中取出我的序列化对象并继续使用它？

我的路线：

XML 序列化消息：

我希望 XML 更像这样：

我有一个消息路由要实现，它的路由会根据消息内容而有所不同。路线的某些部分依赖于其他部分。

例如，如果我有 Data_A，其中有要对其执行的 Task_A 和 Task_B。而 Data_B 只有 Task_B 要对其执行。

这里每个任务都有一个由消费者服务的队列。

如果对数据请求 Task_B，则仅在 Task_B 之后才应执行 Task_A，我该如何设置此类依赖关系？

我是 Messaging 的新手，想知道 、 和 之间ActiveMQ的区别MuleServiceMixCamel

有谁知道这些产品的不同之处吗？

提前致谢 ！

编辑：也想知道学习这些东西的好地方/资源。

我有以下问题。我必须基于 sql 查询生成许多文件。

例如，我从数据库中获取了今天的订单列表，并为每个订单生成文件，然后将每个文件存储在 ftp 上。

理想情况下，我想获得关注。不太清楚如何得到它。

从(MyBean).to(Ftp)

问题和主要问题是如何通过自定义 bean 生成多条消息（例如）。

我不确定在这种情况下拆分器 EIP 是否可以，因为在我的情况下，我不仅要拆分一条消息，而且我只需要生成并发送许多消息。 http://camel.apache.org/splitter.html

我希望，有人遇到过这个问题。

如果任务是只生成一个文件——一切都很简单——你只需要填写 Exchange.OutMessage （或类似的东西）。但是多个文件呢 - 我真的无法得到，如何管理这种情况。

PS对不起，如果这个问题很愚蠢。我是骆驼的新手（仅在轿跑车周内使用它）。这是一个很棒的工具。实际上，这就是为什么我想以最好的方式使用。

非常感谢。

我通过以下方式定义了骆驼文件端点：

我想定义一些文件参数，例如 preMove、move 等。变量 hotfolder 是从 JNDI 获取的字符串，我对它没有影响。当我将属性定义为

它没有被正确解析并且文件得到名称 done/name