クラス 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