使用 spring-camel，我构建了一条从 JMS 主题进行消费的路由（预计为每个输入消息设置 JMSReplyTo），将消息分割成更小的块，将它们发送到 REST 处理器，然后聚合答案并应该生成发送到 JMSReplyTo 指向的目的地的输出消息。不幸的是，camel 在其中一个中间步骤中隐式地利用了 JMSReplyTo 目标（生成未编组的 POJO）。
我们有一个功能要求来调整 JMSReplyTo 以便提供请求-回复消息服务。
我能够在结束路由之前读取 JMSReplyTo 标头，并将其显式转换为 CamelJmsDestinationName，这成功覆盖了 JMS 组件的目标并在输出主题上生成消息。我不确定这是否是最好的方法，问题是camel仍然自己使用JMSReplyTo。
我的RouteBuilder配置如下：
from("jms:topic:T.INPUT")
.process(requestProcessor)
.unmarshal().json(JsonLibrary.Jackson, MyRequest.class)
.split(messageSplitter)
.process(restProcessor)
.aggregate(messagesAggregator)
.unmarshal().json(JsonLibrary.Jackson, BulkResponses.class)
.process(responseProcessor)
.to("jms:topic:recipientTopic");
T.INPUT是输入主题的名称，而recipientTopic只是一个占位符，将被CamelJmsDestinationName替换。
我不热衷于在路由配置中使用 CamelJmsDestinationName 和某种模拟主题名称，因此我愿意寻找更好的解决方案。如果camel能够自动利用JMSReplyTo来生成输出主题的输出消息，那就太好了。
目前的问题是，camel 在 JMSReplyTo 主题上生成中间输出，但输出是一个未编组的 MyRequest 对象，这会导致出现“ClassNotFoundException: (package name).MyRequest”异常，这很明显，因为这只是一个类在我的内部处理中使用 - 我不想将其生成到输出主题。看起来 Camel 确实在 requestProcessor 和 messageSplitter 处理之间隐式使用 JMSReplyTo 目的地...为什么？我究竟做错了什么？最佳实践是什么？
在端点中使用“disableReplyTo=true”。 Camel 不会尝试使用任何回复选项。
Refer: https://camel.apache.org/jms.html https://camel.apache.org/jms.html更多细节
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
