パッケージ 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