パッケージ org.springframework.integration.aggregator
パッケージ org.springframework.integration.aggregator
メッセージ集約に関連するクラスを提供します。
- クラス説明メッセージのグループを単一のメッセージに集約する MessageGroupProcessor 実装の基本クラス。
MessageStore内の相関メッセージのバッファーを保持する抽象メッセージハンドラー。AbstractCorrelatingMessageHandlerのアグリゲーター固有の実装。対応する相関関係を持つメッセージがtriggerメソッドに渡されるか、タイムアウトが発生するまでスレッドを一時停止するメッセージハンドラー。このエンドポイントは、まだ処理されるべきではないメッセージのバリアとして機能します。メッセージを相互に関連付ける方法を決定するための戦略。アグリゲーターコンポーネントにマージするデフォルトヘッダーのFunctionSE 実装。MessageGroupProcessor のこの実装は、MessageGroup からメッセージを受け取り、ペイロードとしてコレクションを使用して単一のメッセージで渡します。提供されたdelegateへの委譲とヘッダーのオプションの集約を使用したMessageGroupProcessor実装。式を評価するCorrelationStrategy実装。SpEL 式を評価するMessageGroupProcessor実装。評価コンテキスト内のルートオブジェクトとしてメッセージリストを使用して SpEL 式を評価するアグリゲーターの基本クラス。式を評価するReleaseStrategy。Reactor のFlux.groupBy(java.util.function.Function<? super T, ? extends K>)およびFlux.window(int)演算子に基づく集約ロジックのAbstractMessageProducingHandler実装。ReleaseStrategyに実装でき、AbstractCorrelatingMessageHandlerで使用して、提供されたグループ条件サプライヤーにデータを取り込むことができる契約。CorrelationStrategyのデフォルト実装。メッセージグループの有効期限を表すイベント。メッセージの相関グループ用のプロセッサー。別の Bean へのアダプターとして機能するCorrelationStrategy実装。POJO メソッドの呼び出しのアダプターとして機能する MessageGroupProcessor。ターゲット POJO でメソッドを呼び出す MessageListProcessor 実装。プレーンオールド Java オブジェクトのメソッドを呼び出すReleaseStrategy。メッセージのグループがいつ完了状態に達するかを決定するための戦略（つまりこのクラスは、デフォルトのリシーケンサーに必要なすべてのストラテジーインターフェースを実装します。AbstractCorrelatingMessageHandlerのリシーケンサー固有の実装。メッセージリストの現在のサイズを予想される "sequenceSize" と単純に比較するReleaseStrategyの実装。グループ内のメッセージを単に返すMessageGroupProcessor。メッセージリストの現在のサイズを予想される "sequenceSize" と単純に比較するReleaseStrategyの実装。次のいずれかに該当する場合にすべてのメッセージを解放するReleaseStrategy: シーケンスが完了している（存在する場合）。ユーザーが設定したしきい値を超えるメッセージがあります。タイムスタンプ（存在する場合）に応じて、最初のメッセージから経過した時間が、ユーザーが設定したタイムアウトを超えています。