0

Camel Multicast EIPを使用しており、集約戦略を次のように指定しています-

<multicast strategyRef="myAggregationStrategy" parallelProcessing="true">
     <to uri="direct1"/>
     <to uri="direct2"/>
</multicast>

XML DSLの集計戦略にcorrelationExpression、completionTimeoutを指定するにはどうすればよいですか？

4

2 に答える 2

0

マルチキャストは集約EIPパターンではありません。マルチキャストの集約戦略は、マルチキャストされた宛先からの応答を集約することです。したがって、ここには2つの宛先があり、したがって、集約されると予想されるメッセージは2つあります。

ただし、マルチキャストされたメッセージの1つが処理に長い時間がかかる場合に備えて、指定できるタイムアウトオプションがあります。

于 2012-05-25T04:20:39.767 に答える
0

マルチキャスト後に指定されたアグリゲーターはマルチキャストエンドポイントによって生成されたメッセージを参照するため、相関識別子は必要ありません。暗黙の「マルチキャスト」相関識別子があると言えます。

マルチキャストタイムアウトについて-マルチキャストDSLでは、すべてのメッセージがエンドポイントに送信されて処理されるまで、マルチキャストが待機する時間を指定できます。

from("direct:start")
.multicast(new MyAggregationStrategy())
  .parallelProcessing().timeout(500).to("direct:a", "direct:b", "direct:c")
.end()
.to("mock:result");
于 2012-05-30T10:16:24.277 に答える