Spring Cloud Dataflowはバッファされたメッセージを出力チャネルに送信します

Question

拒否されたメッセージをバッファするフィルタがあります。私は、述語が満たされたら、バッファリングされたメッセージを出力チャンネルに送信したいと思います。

public class MyFilter implements MessageSelector { 

    private Buffer buff; 

    ... 

    @Override 
    public boolean accept(final Message<?> message) { 
     if (isAcceptable(message))) { 
      for (final Message<?> msg : buff.getBuffered()) { 
       // accept these as well 
      } 
      return true; 
     } else { 
      buff.put(message); 
      return false; 
     } 
    } 
} 

バッファリングされたメッセージを受け入れる方法はありますか？より良いアプローチがありますか？

Answer 1

私は、ReleaseStrategyのaggregatorが良いアプローチであることを示唆しています。リリース戦略がグループを解放するとき、出力プロセッサ（その方法を設定するときは@Aggregatorメソッド）がMessage<?>のコレクションを返した場合、それらは個々のメッセージとして解放されます。

Java設定を使用する場合、@Beanを作成するよりもJava DSL .aggregate(...)関数を使用する方が簡単です。

アグリゲータアプリスターターの現在はpull requestです。