使用 CAMEL 处理确认？

Question

我有客户通过不同的方式发送请求，例如 web 请求、http 请求、soap 请求或通过其他渠道。

在 Camel 中，我将其从各个端点接收到 jms 队列。从队列处理器拿起消息。现在处理器 需要根据客户的偏好（他们已在传入请求中发送）将确认发送给客户。偏好 他们是否希望通过 web 服务或 jms 或文件系统接收确认。

我认为这可以通过http://camel.apache.org/request-reply.html 位来完成，但我无法继续进行下去。基本上我不确定 我应该如何使用 CAMEL 内置功能处理从处理器到各个客户端的确认。任何方向都会有所帮助？

更新：- 客户端偏好存储在来自客户端的传入请求消息中。您也可以假设它存储在系统中的某个位置（数据库或属性文件）

Answer 1

我认为这是您描述的返回地址模式 - https://camel.apache.org/return-address.html

这里的 junit 测试用例中有一些示例代码 - http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToAsHeaderTest.java?view=markup

编辑：从上面的链接中添加一些示例代码以更好地解释它：

假设我们在下面定义了以下端点，我们有一个 from("direct:start"), from("activemq:queue:foo") 和 from("activemq:queue:bar?disableReplyTo=true")

在我们的实际测试中我们称之为代码：

template.sendBodyAndHeader("direct:start", "World", "JMSReplyTo", "queue:bar");

这会向direct:start 端点发送一条消息，其正文包含“World”，标题为JMSReplyTo，值为“queue:bar”。因为我们已经指定了这个JMSReplyTo 标头，所以一旦路由完成，它将调用标头值中定义的任何端点，在这种情况下，它将调用“queue:bar”端点。

@Override
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
    @Override
    public void configure() throws Exception {
        from("direct:start")
            // must enable preserveMessageQos to force Camel to use the JMSReplyTo header
            .to("activemq:queue:foo?preserveMessageQos=true")
            .to("mock:done");

        from("activemq:queue:foo")
            .to("log:foo?showAll=true", "mock:foo")
            .transform(body().prepend("Bye "));

        // we should disable reply to to avoid sending the message back to our self
        // after we have consumed it
        from("activemq:queue:bar?disableReplyTo=true")
            .to("log:bar?showAll=true", "mock:bar");
    }
};
}

那么这如何适合您的用例？那么将会发生的是客户端，或者您编写的某些代码将指定 JMSReplyTo 标头以及与如何发送响应相关的端点。因此，如果他们希望将回复放在队列中，那么 JMSReplyTo 标头的值将是指定的队列端点。