クラス FileAggregator
java.lang.ObjectSE
org.springframework.integration.file.aggregator.FileAggregator
- 実装されたすべてのインターフェース:
Aware
、BeanFactoryAware
、CorrelationStrategy
、GroupConditionProvider
、MessageGroupProcessor
、ReleaseStrategy
public class FileAggregator
extends ObjectSE
implements CorrelationStrategy, ReleaseStrategy, GroupConditionProvider, MessageGroupProcessor, BeanFactoryAware
FileSplitter.FileMarker
ベースの集約ロジックを利用するための便利なコンポーネント。ランタイム最適化のために、3 つすべての CorrelationStrategy
、ReleaseStrategy
、MessageGroupProcessor
を実装します。それぞれ FileHeaders.FILENAME
属性、FileMarkerReleaseStrategy
および FileAggregatingMessageGroupProcessor
を持つ HeaderAttributeCorrelationStrategy
に委譲します。 マーカーが有効になっているデフォルトの FileSplitter
の動作は、シーケンス詳細ヘッダーを提供しないことです。このアグリゲーター実装での相関は、FileSplitter.FileMarker
メッセージを含め、発行された各行の FileSplitter
によって引き続き入力される FileHeaders.FILENAME
ヘッダーによって行われます。
このコンポーネントのデフォルトの動作がターゲットロジックを満たさない場合は、個々の戦略でアグリゲーターを構成することをお勧めします。
- 導入:
- 5.5
- 作成者:
- Artem Bilan
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明boolean
canRelease
(MessageGroup group) getCorrelationKey
(Message<?> message) 指定されたメッセージの相関キーを見つけます。processMessageGroup
(MessageGroup group) 指定された MessageGroup を処理します。void
setBeanFactory
(BeanFactory beanFactory)
コンストラクターの詳細
FileAggregator
public FileAggregator()
メソッドの詳細
setBeanFactory
- 次で指定:
- インターフェース
BeanFactoryAware
のsetBeanFactory
- 例外:
BeansException
getCorrelationKey
インターフェースからコピーされた説明:CorrelationStrategy
指定されたメッセージの相関キーを見つけます。キーを判別できない場合、ストラテジーはnull
を返さないで、例外をスローする必要があります。- 次で指定:
- インターフェース
CorrelationStrategy
のgetCorrelationKey
- パラメーター:
message
- メッセージ。- 戻り値:
- 相関キー。
canRelease
- 次で指定:
- インターフェース
ReleaseStrategy
のcanRelease
getGroupConditionSupplier
- 次で指定:
- インターフェース
GroupConditionProvider
のgetGroupConditionSupplier
processMessageGroup
インターフェースからコピーされた説明:MessageGroupProcessor
指定された MessageGroup を処理します。実装は、呼び出しに基づいて、必要な数のメッセージを自由に返すことができます。たとえば、集約プロセッサーはグループを表す単一のメッセージのみを返しますが、再シーケンスプロセッサーは前のシーケンスが満たされたすべてのメッセージを返します。複数のメッセージが返される場合、戻り値は Collection <Message> でなければなりません。
- 次で指定:
- インターフェース
MessageGroupProcessor
のprocessMessageGroup
- パラメーター:
group
- メッセージグループ。- 戻り値:
- グループを処理した結果。