将消息放入队列后，如何在骆驼路由上发送即时响应

Question

我正在尝试实现一个非常简单的骆驼路由，即从CXFendpoint接收请求，并将其放置在队列中，以便稍后进行异步处理。一旦消息被放置在队列中，我需要能够向调用者发送一个响应，指示消息已被接收。我已经完成了教程，但似乎无法正确完成。所发生的情况是，一旦消息被放置在队列中，在消息从队列处理到其预期目的地之前，不会向调用者发送响应。

下面的代码

    from (SOAP_ENDPOINT)
        .to(SEDA_RECEIVED)
        .transform(constant(OK))//I expect this transform to return OK to caller
        .log("OK response sent back to caller");

    from (SEDA_RECEIVED)
        .to(BEAN_CONVERT_REQUEST)
        .to("activemq:queue:events");

    from ("activemq:queue:events")
            .to(BEAN_STORE_TO_DB);

Answer 1

是的，这是事件消息eiphttp://camel.apache.org/event-message.html

有点相关的是电线抽头eiphttp://camel.apache.org/wire-tap.html

Answer 2

代替to（SEDA_RECEIVED）您可以尝试in比如说（SEDA_RECEIVED）