クラス 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コンストラクター概要
コンストラクターコンストラクター説明IntegrationRSocketEndpointBean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequesterを収集します。ServerRSocketMessageHandler(boolean messageMappingCompatible) IntegrationRSocketEndpointBean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequesterを収集します。方法の概要
修飾子と型メソッド説明voidaddEndpoint(IntegrationRSocketEndpoint endpoint) boolean提供されたキーまたは null によってマップされた接続済みRSocketRequesterを取得します。接続メッセージのキーによってマップされた接続済みのRSocketRequesterを取得します。protected ListSE<? extends HandlerMethodArgumentResolver>protected ListSE<? extends HandlerMethodReturnValueHandler>voidsetApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) voidsetClientRSocketKeyStrategy(BiFunctionSE<MapSE<StringSE, ObjectSE>, DataBuffer, ObjectSE> clientRSocketKeyStrategy) 接続されたRSocketRequesterをマッピングするためのキーを抽出するようにBiFunctionSE を構成します。クラス 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()IntegrationRSocketEndpointBean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequesterを収集します。ServerRSocketMessageHandler
public ServerRSocketMessageHandler(boolean messageMappingCompatible) IntegrationRSocketEndpointBean に委譲するためのサービス側の RSocket メッセージハンドラーインスタンスを作成し、クライアント接続からRSocketRequesterを収集します。messageMappingCompatible == trueの場合、このクラスは、標準のRSocketMessageHandlerと同じようにMessageMappingメソッドも処理します。- パラメーター:
messageMappingCompatible-MessageMappingも処理するかどうか。
方法の詳細
setClientRSocketKeyStrategy
public void setClientRSocketKeyStrategy(BiFunctionSE<MapSE<StringSE, ObjectSE>, DataBuffer, ObjectSE> clientRSocketKeyStrategy) 接続されたRSocketRequesterをマッピングするためのキーを抽出するようにBiFunctionSE を構成します。デフォルトでは、クライアントが接続されているdestinationです。- パラメーター:
clientRSocketKeyStrategy- 使用するBiFunctionSE。
getClientRSocketRequesters
接続メッセージのキーによってマップされた接続済みのRSocketRequesterを取得します。getClientRSocketRequester
提供されたキーまたは null によってマップされた接続済みRSocketRequesterを取得します。- パラメーター:
key- マップされたRSocketRequesterのキー（存在する場合）。- 戻り値:
- マップされた
RSocketRequesterまたは null。
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware内のsetApplicationEventPublisher
detectEndpoints
public boolean detectEndpoints()addEndpoint
initArgumentResolvers
- オーバーライド:
- クラス
MessageMappingMessageHandlerのinitArgumentResolvers
initReturnValueHandlers
- オーバーライド:
- クラス
RSocketMessageHandlerのinitReturnValueHandlers