带有外部 ActiveMQ 代理的 Apache camel

Question

我正在学习使用 Apache Camel 来解决消息传递问题。以下几点解释了问题的要点。

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

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

谢谢！

Answer 1

• 使用 camel-activemq 连接到您的 ActiveMQ 代理
• 使用camel json marshalling 支持将请求转换为这种格式...

只需要像这样设置你的activemq 组件

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

然后定义路由以从 ActiveMQ 队列中产生/使用，根据需要转换为 JSON 或从 JSON...

例如...接受客户端请求、转换为 JSON 并发送到队列的路径

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

然后从另一个队列中提取另一个路由并从 JSON 中解组并用它做一些事情......

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