クラス ServerRSocketMessageHandler
java.lang.ObjectSE
org.springframework.messaging.handler.invocation.reactive.AbstractMethodMessageHandler<CompositeMessageCondition>
org.springframework.messaging.handler.annotation.reactive.MessageMappingMessageHandler
org.springframework.messaging.rsocket.annotation.support.RSocketMessageHandler
org.springframework.integration.rsocket.ServerRSocketMessageHandler
- 実装されたすべてのインターフェース:
Aware
、BeanNameAware
、InitializingBean
、ApplicationContextAware
、ApplicationEventPublisherAware
、EmbeddedValueResolverAware
、ReactiveMessageHandler
public class ServerRSocketMessageHandler
extends RSocketMessageHandler
implements ApplicationEventPublisherAware
RSocket サービス側の
IntegrationRSocketMessageHandler
拡張。 プレーンな Spring Integration アプリケーションでは、このクラスのインスタンスは ServerRSocketConnector
によって内部的に作成され、そこで新しい RSocket サーバーが起動されます。既存の RSocket サーバーを使用している場合、このクラスのインスタンスを RSocketMessageHandler.responder()
としてそのサーバーに提供する必要があり、ServerRSocketConnector
はデリゲートとして同じインスタンスを受け入れる必要があります。
messageMappingCompatible
オプションを使用すると、このクラスは MessageMapping
メソッドも処理し、Spring Integration と標準の RSocketMessageHandler
機能の両方をカバーします。
- 導入:
- 5.2.1
- 作成者:
- Artem Bilan
フィールドサマリー
フィールドクラス org.springframework.messaging.handler.invocation.reactive.AbstractMethodMessageHandler から継承されたフィールド
logger
コンストラクターのサマリー
コンストラクターコンストラクター説明IntegrationRSocketEndpoint
Bean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequester
を収集します。ServerRSocketMessageHandler
(boolean messageMappingCompatible) IntegrationRSocketEndpoint
Bean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequester
を収集します。メソッドのサマリー
修飾子と型メソッド説明void
addEndpoint
(IntegrationRSocketEndpoint endpoint) boolean
提供されたキーまたは null によってマップされた接続済みRSocketRequester
を取得します。接続メッセージのキーによってマップされた接続済みのRSocketRequester
を取得します。protected ListSE<? extends HandlerMethodArgumentResolver>
protected ListSE<? extends HandlerMethodReturnValueHandler>
void
setApplicationEventPublisher
(ApplicationEventPublisher applicationEventPublisher) void
setClientRSocketKeyStrategy
(BiFunctionSE<MapSE<StringSE, ObjectSE>, DataBuffer, ObjectSE> clientRSocketKeyStrategy) 接続されたRSocketRequester
をマッピングするためのキーを抽出するようにBiFunction
SE を構成します。クラス org.springframework.messaging.rsocket.annotation.support.RSocketMessageHandler から継承されたメソッド
afterPropertiesSet, extendMapping, getCondition, getDefaultDataMimeType, getDefaultMetadataMimeType, getEncoders, getMetadataExtractor, getRSocketStrategies, handleNoMatch, responder, responder, setDecoders, setDefaultDataMimeType, setDefaultMetadataMimeType, setEncoders, setMetadataExtractor, setReactiveAdapterRegistry, setRouteMatcher, setRSocketStrategies
クラス org.springframework.messaging.handler.annotation.reactive.MessageMappingMessageHandler から継承されたメソッド
createExceptionMethodResolverFor, getConversionService, getDecoders, getDestination, getDirectLookupMappings, getMappingComparator, getMappingForMethod, getMatchingMapping, getRouteMatcher, getValidator, handleMatch, obtainRouteMatcher, processDestinations, registerMessagingAdvice, setConversionService, setEmbeddedValueResolver, setValidator
クラス org.springframework.messaging.handler.invocation.reactive.AbstractMethodMessageHandler から継承されたメソッド
detectHandlerMethods, getApplicationContext, getArgumentResolverConfigurer, getArgumentResolvers, getBeanName, getDestinationLookup, getHandlerMethods, getHandlerPredicate, getReactiveAdapterRegistry, getReturnValueHandlerConfigurer, handleMessage, registerExceptionHandlerAdvice, registerHandlerMethod, setApplicationContext, setArgumentResolverConfigurer, setBeanName, setHandlerPredicate, setHandlers, setReturnValueHandlerConfigurer
フィールドの詳細
messageMappingCompatible
protected final boolean messageMappingCompatible
コンストラクターの詳細
ServerRSocketMessageHandler
public ServerRSocketMessageHandler()IntegrationRSocketEndpoint
Bean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequester
を収集します。ServerRSocketMessageHandler
public ServerRSocketMessageHandler(boolean messageMappingCompatible) IntegrationRSocketEndpoint
Bean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequester
を収集します。messageMappingCompatible == true
の場合、このクラスは、標準のRSocketMessageHandler
と同じようにMessageMapping
メソッドも処理します。- パラメーター:
messageMappingCompatible
-MessageMapping
も処理するかどうか。
メソッドの詳細
setClientRSocketKeyStrategy
public void setClientRSocketKeyStrategy(BiFunctionSE<MapSE<StringSE, ObjectSE>, DataBuffer, ObjectSE> clientRSocketKeyStrategy) 接続されたRSocketRequester
をマッピングするためのキーを抽出するようにBiFunction
SE を構成します。デフォルトでは、クライアントが接続されているdestination
です。- パラメーター:
clientRSocketKeyStrategy
- 使用するBiFunction
SE。
getClientRSocketRequesters
接続メッセージのキーによってマップされた接続済みのRSocketRequester
を取得します。getClientRSocketRequester
提供されたキーまたは null によってマップされた接続済みRSocketRequester
を取得します。- パラメーター:
key
- マップされたRSocketRequester
のキー(存在する場合)。- 戻り値:
- マップされた
RSocketRequester
または null。
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware
のsetApplicationEventPublisher
detectEndpoints
public boolean detectEndpoints()addEndpoint
initArgumentResolvers
- オーバーライド:
- クラス
MessageMappingMessageHandler
のinitArgumentResolvers
initReturnValueHandlers
- オーバーライド:
- クラス
RSocketMessageHandler
のinitReturnValueHandlers