问题标签 [camel-jms]

我正在使用 apache-camel 作为路由引擎设置一个 ServieMix 实例，我的路由在 blueprint.xml 中定义。我正在尝试为我的蓝图配置 ActiveMQ，使其与其他任何东西完全隔离（使用它自己的、私有的、代理）。

这是我的骆驼蓝图 XML

我认为它根本没有使用设置，因为我收到以下错误

amq-broker 是默认代理。

我倾尽所有我能找到的东西，但缺少一些重要的东西

• http://camel.apache.org/activemq.html
• http://activemq.apache.org/networks-of-brokers.html
• http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html

• http://activemq.apache.org/xml-configuration.html

• 我无法使用xmlns:amq="http://activemq.apache.org/schema/core"（ServiceMix 无法解决）

我在用

• 服务混合 7.0.0
• 阿帕奇骆驼/骆驼蓝图 2.16.4
• activemq-client/camel/蓝图 5.14.3

长话短说，我如何正确配置 ActiveMQ 以使我的蓝图与其他任何东西完全隔离？

我正在尝试处理由 3 个 RouteBuilder 组成的骆驼路线上的异常。主路由（调用其他路由）由 jms 队列触发，我想处理第一条路由上的所有异常。

主要路线：

第二条路线（由主路线调用。调用第三条路线并保存数据）：

秒调用的最后一条路由（进行 http GET 调用并进行映射操作）：

我捕获所有异常并将其包装在我的对象“SystemErrorException”中。onException 处理程序是：

问题是当异常发生时 camelRedeliveryCounter 总是值为 1，并且异常处理程序进入无限循环重试。有什么建议么？

I am trying to move the message from a queue1(Dead Letter queue) to queue2 in active MQ at periodic interval of 5 minutes using Camel router. I am using below code to achieve this :-

Problem here is that:- Camel routing gets enabled after 5 minutes. It moves the message from DLQ (DLQ.Consumer.OUTDOCS.VirtualTopic.queue1) to queue1 (Consumer.OUTDOCS.VirtualTopic.queue1). But if message is poison , it again comes back to DLQ and again routing moves the message from DLQ to normal queue and this process keeps on running infinitely.

My requirement is that routing should move the message once only from DLQ to queue after every 5 minutes ? if poison message comes, it should check after 5 minutes only.

我必须解组 xml 并将对象发送到 cxf 组件。最初我一直在使用“vm”队列来做这件事，它工作正常。现在我想用 'jms' 队列替换它，而这样做的对象不能转移到 jms 队列中。我没有将对象放入 jms 队列。

我有一个 Camel 路由，它使用队列中的消息并将消息存储到数据库中。现在我想以优雅的方式手动关闭正在运行的骆驼路线。每当我需要停止 Camel 路线时，我都会触发一个 RestEndpoint。这个端点应该停止路由。但是，如果在关闭期间有任何正在运行的消息或事务正在运行，则它必须成功完成而不消耗来自骆驼路由的 from("") 端点的任何新消息，并在完成飞行消息或事务后关闭。谁能帮助我如何编码？

我已经用过几次骆驼了，但这个问题已经超出了我的想象，我不知道我做错了什么。它是一个新应用程序，应该从 IBM MQ 获取消息并将文件放置到磁盘。路线很简单：

以下是创建连接工厂时使用的代码：

在应用程序启动并测试连接后，它立即开始关闭。不抛出异常。在本地测试时，我使用不同的配置文件并连接到 ActiveMQ 服务器。这运行良好，并做了它应该做的事情。

任何帮助将不胜感激！

/卡特琳娜

这是路由关闭之前的日志摘录：

我正在使用请求-回复模式以同步方式使用骆驼 jms。骆驼路由公开了一个 cxf 端点，它将消息放入 jms 队列中，另一个组件处理它并在回复队列中发送响应。

在接收来自回复队列的回复时创建了一个新线程？我在骆驼路线中使用 log4j MDC 时遇到问题。存储在 MDC 中的值不再可用？

是骆驼 jms 请求/回复模式的行为吗？

下面是 JMS 端点：

我的目标是使用 Camel 及其 JMS 组件。

路线配置如下所示 -

我想在此路由中添加“参数”类型的选项并键入“对象” - 例如选项“jmsMessageType”。

我看到其他一些关于在路由定义上使用 setProperty() 的帖子，但我找不到明确的答案。“字符串”和数字类型的选项可以附加到 URI，但不能附加到对象。

JMS 有一个 taskExecutor 选项，但我如何将它的实例添加到 URI 以进行路由。

我正在使用 Stringboot、springboot starter artemis 和 camel

这是我对他们的依赖：

这是我的代码（由于某种原因，我在这里没有使用 jms 模板）

我正在尝试使用 JmsMessageUUID 选择消息，它基本上是在发送消息期间设置的随机字符串，Jms 选择器无法找到消息，但是当我不使用选择器而不是成功使用消息时，我也检查了 jms 属性收到消息，并且 JmsMessageUUID 在具有相同字符串值的属性中可用。

我无法弄清楚为什么选择器不起作用？请在这里帮助我..

我还发现JMSMessageID过滤器适用于Queue但不适用于 Topoc:(

我可以使用camel context [xml]从activemq读取消息，但我只想不读取任何消息，例如，如果队列包含10 000条消息，我们只想读取前1 000条消息，剩余的不应该'不要被触动。

我是骆驼新手