带有外部ActiveMQ代理的Apache camel

Question

我正在学习使用ApacheCamel解决一个消息传递问题，以下几点说明问题的要点。

1. 有一个外部ActiveMQ代理，它需要JSON格式的消息，并返回JSON格式的响应
2. 发送给代理的JSON消息必须在运行时通过从用户获取参数来创建
3. 返回的响应将返回给用户

我发现很难按照书中的例子来解决我的问题。请让我知道如何使用ApacheCamel解决这个问题。

谢谢！

Answer 1

• 使用camel-active emq连接到您的ActiveMQ代理
• 使用camel json编组支持将请求转换为此格式...

只需要像这样设置activemq组件

  <bean id="activemq"
        class="org.apache.activemq.camel.component.ActiveMQComponent">
        <property name="brokerURL" value="tcp://mybroker:61616"/>    
  </bean>

然后定义从ActiveMQ队列产生/消耗的路由，根据需要转换到/从JSON...

例如其中一个路由接收客户端请求，转换为JSON并发送到队列

from("direct:clientRequest")
    .marshal().json()
    .to("activemq:firstQueue");

然后从另一个队列和JSON散集拾取另一条路由，并对其做些什么...

from("activemq:otherQueue")
    .unmarshal().json()
    .to("<do something>");