クラス ReactiveMessageHandlerAdapter
java.lang.ObjectSE
org.springframework.integration.handler.ReactiveMessageHandlerAdapter
- 実装されているすべてのインターフェース:
MessageHandler
ReactiveMessageHandler を同期呼び出しに適合させるための MessageHandler 実装。ReactiveMessageHandler.handleMessage(Message) 呼び出しから返されたリアクティブ型へのサブスクリプションは、handleMessage(org.springframework.messaging.Message<?>) 実装で直接行われます。 フレームワークは、XML およびアノテーションの構成のために、ターゲット ReactiveMessageHandler をこのインスタンスに自動的にラップします。Java DSL の場合、一般的な使用箇所(.handle(MessageHandle))でラップすることをお勧めします。または、プロトコル固有の ReactiveMessageHandler の MessageHandlerSpec 実装でラップする必要があります。
フレームワークは、リアクティブストリームを構成できるときはいつでも、デリゲート ReactiveMessageHandler をアンラップします。ReactiveStreamsConsumer。
- 導入:
- 5.3
- 作成者:
- Artem Bilan
- 関連事項:
コンストラクターの概要
コンストラクターコンストラクター説明ReactiveMessageHandlerAdapter(ReactiveMessageHandler reactiveMessageHandler) 提供されたReactiveMessageHandlerに基づいてインスタンス化します。メソッドのサマリー
コンストラクターの詳細
ReactiveMessageHandlerAdapter
提供されたReactiveMessageHandlerに基づいてインスタンス化します。- パラメーター:
reactiveMessageHandler- 委譲先のReactiveMessageHandler。
メソッドの詳細
getDelegate
デリゲートReactiveMessageHandlerへのアクセスを取得します。通常、フレームワークの内部でリアクティブストリームを内部で構成し、明示的なsubscribe()呼び出しを回避できるコンポーネントで使用されます。- 戻り値:
- このインスタンスが委譲している
ReactiveMessageHandler。
handleMessage
- 次で指定:
- インターフェース
MessageHandlerのhandleMessage - 例外:
MessagingException