クラス MessageHandlerChain

実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>AwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanApplicationContextAwareLifecycleOrderedComponentSourceAwareExpressionCapableOrderableMessageProducerCompositeMessageHandlerHeaderPropagationAwareIntegrationPatternNamedComponentIntegrationManagementManageableLifecycleTrackableComponentMessageHandlerreactor.core.CoreSubscriber<Message<?>>

public class MessageHandlerChain extends AbstractMessageProducingHandler implements CompositeMessageHandler, ManageableLifecycle
MessageHandler インスタンスのチェーンを順番に呼び出す複合 MessageHandler 実装。

最後のハンドラーを除く各ハンドラーは、MessageProducer インターフェースを実装する必要があります。最後のハンドラーは、チェーン自体に出力チャネルが構成されている場合にも必要です。ハンドラーの型について他の前提はありません。

強制されていませんが、各ハンドラーが応答メッセージを生成してその出力チャネルに送信することが期待されます。たとえば MessageFilter を使用して、チェーンの途中でメッセージをフィルタリングすることができます。null を返す MessageHandler でも同じ効果がありますが、このオプションはあまり表現力がありません。

このコンポーネントを名前空間から使用して、暗黙的に作成できるチャネルを削除することにより、構成の可読性を向上させることができます。

 
 <chain>
     <filter ref="someFilter"/>
     <bean class="SomeMessageHandlerImplementation"/>
     <transformer ref="someTransformer"/>
     <aggregator ... />
 </chain>
 
 
作成者:
Mark Fisher, Iwein Fuld, Gary Russell, Artem Bilan, Trung Pham, Christian Tzolov