public class ReactiveMessageHandlerAdapter extends ObjectSE implements MessageHandler
ReactiveMessageHandler を同期呼び出しに適合させるための MessageHandler 実装。ReactiveMessageHandler.handleMessage(Message) 呼び出しから返されたリアクティブ型へのサブスクリプションは、handleMessage(org.springframework.messaging.Message<?>) 実装で直接行われます。 フレームワークは、XML およびアノテーションの構成のために、ターゲット ReactiveMessageHandler をこのインスタンスに自動的にラップします。Java DSL の場合、一般的な使用箇所（.handle(MessageHandle)）でラップすることをお勧めします。または、プロトコル固有の ReactiveMessageHandler の MessageHandlerSpec 実装でラップする必要があります。
フレームワークは、リアクティブストリームを構成できるときはいつでも、デリゲート ReactiveMessageHandler をアンラップします。ReactiveStreamsConsumer。
ReactiveStreamsConsumer| コンストラクターと説明 |
|---|
ReactiveMessageHandlerAdapter(ReactiveMessageHandler reactiveMessageHandler) 提供された ReactiveMessageHandler に基づいてインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ReactiveMessageHandler | getDelegate() デリゲート ReactiveMessageHandler へのアクセスを取得します。 |
void | handleMessage(Message<?> message) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic ReactiveMessageHandlerAdapter(ReactiveMessageHandler reactiveMessageHandler)
ReactiveMessageHandler に基づいてインスタンス化します。reactiveMessageHandler - 委譲先の ReactiveMessageHandler。public ReactiveMessageHandler getDelegate()
ReactiveMessageHandler へのアクセスを取得します。通常、フレームワークの内部でリアクティブストリームを内部で構成し、明示的な subscribe() 呼び出しを回避できるコンポーネントで使用されます。ReactiveMessageHandler。public void handleMessage(Message<?> message) throws MessagingException
MessageHandler の handleMessage MessagingException