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

クラス DelegatingMessageGroupProcessor

java.lang.ObjectSE
org.springframework.integration.aggregator.DelegatingMessageGroupProcessor
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、Lifecycle、MessageGroupProcessor、ManageableLifecycle
public class DelegatingMessageGroupProcessor extends ObjectSE implements MessageGroupProcessor, BeanFactoryAware, ManageableLifecycle
提供された delegate への委譲とヘッダーのオプションの集約を使用した MessageGroupProcessor 実装。

AbstractAggregatingMessageGroupProcessor とは異なり、このプロセッサーは delegate 呼び出しの結果をチェックし、結果が Message または AbstractIntegrationMessageBuilder でない場合にのみ、ヘッダーを出力に集約します。

このプロセッサーは、集約ヘッダー FunctionSE が提供されている場合に、提供されている非標準 MessageGroupProcessor をラップするために内部的に使用されます。POJO メソッドの呼び出しまたは SpEL 式の評価には、AbstractAggregatingMessageGroupProcessor 実装を使用することをお勧めします。

導入:
5.2
作成者:
Artem Bilan

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

  • メソッドの詳細

    • setBeanFactory

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

    • processMessageGroup

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

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

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

    • start

      public void start()
      次で指定:
      インターフェース Lifecycle の start 
      次で指定:
      インターフェース ManageableLifecycle の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle の stop 
      次で指定:
      インターフェース ManageableLifecycle の stop 

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle の isRunning 
      次で指定:
      インターフェース ManageableLifecycle の isRunning