用CAMEL处理确认？

Question

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

在 Camel 中，我从各自的endpoint接收它到 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

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

假设我们在下面定义了以下endpoint，我们有一个from（“direct：start”），from（“activemq：queue：foo”）和from（“activemq：queue：bar？disableReplyTo=true”）

在实际测试中，我们称此代码为：

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

这将向direct:startendpoint发送一条消息，消息体包含“World”和一个名为JMSReplyTo的头，值为“queue:bar”。因为我们已经指定了这个＜code＞JMSReplyTo＜/code＞头，所以一旦路由完成，它将调用头值中定义的任何endpoint，在这种情况下，它将呼叫“queue:bar”endpoint。

@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标头，其中包含与如何发送响应相关的endpoint。因此，如果他们希望将应答放在队列中，那么JMSReplyTo标头的值将是指定的队列endpoint。