パッケージ org.springframework.integration.aggregator

クラス AbstractAggregatingMessageGroupProcessor

java.lang.ObjectSE
org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、MessageGroupProcessor
既知の直属サブクラス
DefaultAggregatingMessageGroupProcessor、ExpressionEvaluatingMessageGroupProcessor、FileAggregatingMessageGroupProcessor、MethodInvokingMessageGroupProcessor
public abstract class AbstractAggregatingMessageGroupProcessor extends ObjectSE implements MessageGroupProcessor, BeanFactoryAware
メッセージのグループを単一のメッセージに集約する MessageGroupProcessor 実装の基本クラス。
導入:
2.0
作成者:
Iwein Fuld, Alexander Peters, Mark Fisher, Dave Syer, Gary Russell, Artem Bilan

  • フィールドの詳細

    • logger

      protected final Log logger

  • コンストラクターの詳細

    • AbstractAggregatingMessageGroupProcessor

      public AbstractAggregatingMessageGroupProcessor()

  • メソッドの詳細

    • setBeanFactory

      public void setBeanFactory(BeanFactory beanFactory) throws BeansException
      次で指定:
      インターフェース BeanFactoryAware の setBeanFactory 
      例外:
      BeansException

    • setHeadersFunction

      public void setHeadersFunction(FunctionSE<MessageGroup,MapSE<StringSE,ObjectSE>> headersFunction)
      FunctionSE を指定して、MessageGroup を出力メッセージ用の合成ヘッダーにマップします。
      パラメーター:
      headersFunction - 使用する FunctionSE。
      導入:
      5.2

    • getHeadersFunction

      protected FunctionSE<MessageGroup,MapSE<StringSE,ObjectSE>> getHeadersFunction()

    • getMessageBuilderFactory

      protected MessageBuilderFactory getMessageBuilderFactory()

    • processMessageGroup

      public final ObjectSE processMessageGroup(MessageGroup group)
      インターフェースからコピーされた説明: MessageGroupProcessor
      指定された MessageGroup を処理します。実装は、呼び出しに基づいて、必要な数のメッセージを自由に返すことができます。たとえば、集約プロセッサーはグループを表す単一のメッセージのみを返しますが、再シーケンスプロセッサーは前のシーケンスが満たされたすべてのメッセージを返します。

      複数のメッセージが返される場合、戻り値は Collection <Message> でなければなりません。

      次で指定:
      インターフェース MessageGroupProcessor の processMessageGroup 
      パラメーター:
      group - メッセージグループ。
      戻り値:
      グループを処理した結果。

    • aggregateHeaders

      protected MapSE<StringSE,ObjectSE> aggregateHeaders(MessageGroup group)
      このデフォルトの実装は、グループ間で競合のないすべてのヘッダーを返すだけです。グループ内の 1 つ以上のメッセージにヘッダーがない場合、競合とは見なされません。サブクラスは、必要に応じて、より高度な競合解決戦略でこのメソッドをオーバーライドできます。
      パラメーター:
      group - メッセージグループ。
      戻り値:
      集約されたヘッダー。

    • aggregatePayloads

      protected abstract ObjectSE aggregatePayloads(MessageGroup group, MapSE<StringSE,ObjectSE> defaultHeaders)