4

CXF エンドポイントからリクエストを受信し、後で非同期処理するためにキューに入れる、非常に単純なキャメル ルートを実装しようとしています。メッセージがキューに配置されたら、メッセージを受信したことを示す応答を発信者に送信できるようにする必要があります。チュートリアルを完了しましたが、これを正しく機能させることができないようです。メッセージがキューに置かれると、メッセージがキューから目的の宛先に処理されるまで、呼び出し元に応答が送信されません。

以下のコード

    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);
4

2 に答える 2

1

ええ、そのイベントメッセージeip http://camel.apache.org/event-message.html

少し関連するのは、ワイヤータップ eip http://camel.apache.org/wire-tap.htmlです。

于 2012-11-24T08:07:12.233 に答える
1

to(SEDA_RECEIVED) の代わりに inOnly(SEDA_RECEIVED) を試すことができます

于 2012-11-23T06:31:22.790 に答える