2016-06-11 4 views
0

スキャッターギャザーをカスタムAggregationStrategyで使用しています。この散布図には、いくつかのWebサービスコンシューマーが集まっています。そして、私は...このようなイベントからなどのメッセージプロセッサ名、オリジナルのペイロード、アウトバウンドアドレスと、この消費者の情報を取得するためにそのようなミュールスキャッター収集カスタムアグリゲーションメッセージプロセッサー

何か必要があります。

public class CustomAggregation implements AggregationStrategy { 
    @Override 
    public MuleEvent aggregate(AggregationContext context) throws MuleException { 
     for (MuleEvent event : context.collectEventsWithoutExceptions()) { 
      ...get message processor name from event... 
      ...get message processor payload from event... 
     } 
     for (MuleEvent event : context.collectEventsWithExceptions()) { 
      ...get message processor name from event... 
      ...get message processor payload from event... 
     } 
    } 
} 

をしかし、私は、メッセージプロセッサについて何かを見つける傾けますこのイベント。これをどうやって得るのですか?

答えて

0

メッセージプロセッサペイロードは、各MuleEventのMuleMessage(event.getMessage().getPayload())にあります。私はメッセージプロセッサーの名前やそれがどうして必要なのか分かりません。たぶん、散布集まりの各ルートに必要なデータでプロパティーや変数を設定できます。 HTH

+0

"ルート1のエラー"は有益ではありません.. –

+0

エラーがあった場合、MuleMessageは有益な例外ペイロードを持ち、 '' event.getMessage() .getExceptionPayload() '' '。 – afelisatti

+0

しかし、どのルートが失敗するかについての情報はありません。私はいくつかの同様のWebサービスのコンシューマーを持っています。 Like "アドレスが****のWebサービスでエラーが発生しました"。そして私は成功した応答も記録したい。 –