驼峰截获/封送jms回复

Question

我试图在camel中获取请求/回复jms消费者，收到了传入消息，我可以看到camel也发送了回复，但消息没有被封送。

我正在使用拦截器封送所有来自activemqendpoint的消息

OsdrDataFormat osdrDataFormat = new OsdrDataFormat();

interceptFrom("activemq:*").unmarshal(osdrDataFormat);
interceptSendToEndpoint("activemq:*").marshal(osdrDataFormat);

（我扩展了JacksonDataFormat，以便在封送消息时填充JMSType。）

对于正常的单向交换，这是可行的（例如）

from("activemq:queue:test").bean(TestComponent.class, "test");
from("direct:test-input").to("activemq:queue:test");

但是当我走这条路的时候

from("activemq:queue:test").bean(TestComponent.class, "test");

并将带有JMSReplyTo消息的消息发送到测试队列（使用activemq管理页面），我可以看到camel确实发送了回复消息，但它没有被封送到json。

手动添加封送确实有效，但我更喜欢使用拦截器，因为这样可以创建一个抽象的RouteBuilder，并在默认情况下将拦截器添加到每个路由。

from("activemq:queue:test").bean(TestComponent.class, "test").marshal(osdrDataFormat);

有人知道解决这个问题的方法吗？或者是一种更好的方法来确保来自和到activemq的所有消息都被封送？

我还发现了这个线程：Apache Camel inOut路由，使用jaxb进行交换封送/解封送，但这里的答案是使用手动封送。

Answer 1

只有当Camel将消息发送到Camelendpoint时，才出现截取发送到endpoint的情况，而不是当JMS组件内部将一些JMS消息发送到某个JMS目标时。这不一样。