インターフェースの使用
org.springframework.integration.aggregator.MessageGroupProcessor
MessageGroupProcessor を使用するパッケージ
パッケージ
説明
メッセージ集約に関連するクラスを提供します。
Spring Integration Java DSL のルートパッケージ。
ファイルベースの集約ロジックのサポートクラスを提供します。
org.springframework.integration.aggregator 内の MessageGroupProcessor 使用
修飾子と型クラス説明classメッセージのグループを単一のメッセージに集約する MessageGroupProcessor 実装の基本クラス。classMessageGroupProcessor のこの実装は、MessageGroup からメッセージを受け取り、ペイロードとしてコレクションを使用して単一のメッセージで渡します。class提供されたdelegateへの委譲とヘッダーのオプションの集約を使用したMessageGroupProcessor実装。classSpEL 式を評価するMessageGroupProcessor実装。classPOJO メソッドの呼び出しのアダプターとして機能する MessageGroupProcessor。classこのクラスは、デフォルトのリシーケンサーに必要なすべてのストラテジーインターフェースを実装します。classグループ内のメッセージを単に返すMessageGroupProcessor。修飾子と型メソッド説明AbstractCorrelatingMessageHandler.getOutputProcessor()構成済みのMessageGroupProcessorを返します。型 MessageGroupProcessor のパラメーターを持つ org.springframework.integration.aggregator のメソッド修飾子と型メソッド説明voidAbstractCorrelatingMessageHandler.setOutputProcessor(MessageGroupProcessor outputProcessor) 出力関数にMessageGroupProcessorを指定します。型 MessageGroupProcessor のパラメーターを持つ org.springframework.integration.aggregator のコンストラクター修飾子コンストラクター説明AbstractCorrelatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store) AbstractCorrelatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) AggregatingMessageHandler(MessageGroupProcessor processor) AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store) AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) BarrierMessageHandler(long requestTimeout, long triggerTimeout, MessageGroupProcessor outputProcessor) 提供されたタイムアウトと出力プロセッサー、およびデフォルトの相関戦略を使用してインスタンスを構築します。BarrierMessageHandler(long requestTimeout, long triggerTimeout, MessageGroupProcessor outputProcessor, CorrelationStrategy correlationStrategy) 提供されたタイムアウトと出力プロセッサー、およびデフォルトの相関戦略を使用してインスタンスを構築します。BarrierMessageHandler(long timeout, MessageGroupProcessor outputProcessor) 提供されたタイムアウトと出力プロセッサー、およびデフォルトの相関戦略を使用してインスタンスを構築します。BarrierMessageHandler(long timeout, MessageGroupProcessor outputProcessor, CorrelationStrategy correlationStrategy) 提供されたタイムアウトと出力プロセッサー、およびデフォルトの相関戦略を使用してインスタンスを構築します。DelegatingMessageGroupProcessor(MessageGroupProcessor delegate, FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) ResequencingMessageHandler(MessageGroupProcessor processor) ResequencingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store) ResequencingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) org.springframework.integration.dsl 内の MessageGroupProcessor 使用
型 MessageGroupProcessor のパラメーターを持つ org.springframework.integration.dsl のメソッド修飾子と型メソッド説明AggregatorSpec.outputProcessor(MessageGroupProcessor outputProcessor) 解放されたグループからの出力メッセージを判別するプロセッサー。BarrierSpec.outputProcessor(MessageGroupProcessor outputProcessor) org.springframework.integration.file.aggregator 内の MessageGroupProcessor 使用
修飾子と型クラス説明classmarkersオプションがオンになっているFileSplitterによって以前に分割されたファイルコンテンツを収集するためのAbstractAggregatingMessageGroupProcessor実装。classFileSplitter.FileMarkerベースの集計ロジックを利用するための便利なコンポーネント。