2016-12-09 12 views
0

私はCamel Multicastから奇妙な動作をしています。私は間違ったことをしているように見えますが、それを指摘することはできません。Camel Multicastが異常に動作しています

Iは以下のように2つのエンドポイントへのマルチキャストルートを作成しています:

Start point : direct://start 
endpoint : direct://route1 
endpoint : direct://route2 

ルート情報:

1)from("direct://start").process(new DeepCloneRequest()).multicast(new Aggregator()).to("direct://route1","direct://route2")

2)from("direct://route1").setheader(<to use later in processor>).process(<do some preprocessing>).to("rest url1").processor(<to do post processing>).end

3)from("direct://route2").setheader(<to use later in processor>).process(<do some preprocessing>).to("rest url2").processor(<to do post processing>).end

私は何ですか?氷は私のルート3の前処理で、マルチキャストからDeepCloneRequestの代わりに2番の前処理の交換を得たということです。

誰か助けてもらえますか?私はルート2と3の両方でマルチキャストを受信するという同じ要求を出したいと思っています。

私が使用しているCamelのバージョンは2.17.3です。

答えて

1

あなたは、その後、http://camel.apache.org/multicast.html

「マルチキャストは各コピー元Exchangeおよびマルチキャストをコピーします。ただしコピーは浅いコピーである、場合にあなたがmutateableメッセージ本文を持っているので、を参照してください、onPrepare機能を使用する必要がありますの変更は、他のコピーされたメッセージによって表示されます。深いクローンコピーを使用する場合は、プロセッサインタフェースを使用してこれを行うためのカスタムonPrepareを使用する必要があります。

関連する問題