クラス RSocketOutboundGateway

メソッドの詳細

• setClientRSocketConnector

  public void setClientRSocketConnector(ClientRSocketConnector clientRSocketConnector)

  ClientRSocketConnector.getRequester() によって提供される接続に基づいて、クライアント側のリクエストに対して ClientRSocketConnector を構成します。サーバー側の場合、リクエストメッセージの RSocketRequesterMethodArgumentResolver.RSOCKET_REQUESTER_HEADER ヘッダーに RSocketRequester を指定する必要があります。

  パラメーター:

  clientRSocketConnector - 使用する ClientRSocketConnector。

• setInteractionModel

  public void setInteractionModel(RSocketInteractionModel interactionModel)

  RSocket リクエスト型の RSocketInteractionModel を構成します。

  パラメーター:

  interactionModel - 使用する RSocketInteractionModel。

  導入:

  5.2.2

• setInteractionModelExpression

  public void setInteractionModelExpression(Expression interactionModelExpression)

  リクエストメッセージに対して実行時に RSocket リクエスト型の RSocketInteractionModel を評価するように SpEL 式を構成します。

  パラメーター:

  interactionModelExpression - 使用する SpEL 式。

  導入:

  5.2.2

• setPublisherElementType

  public void setPublisherElementType(ClassSE<?> publisherElementType)

  リクエスト Publisher 要素の型を構成します。

  パラメーター:

  publisherElementType - リクエスト Publisher 要素の型。

  関連事項:

  • RSocketRequester.RequestSpec.data(Object, Class)

• setPublisherElementTypeExpression

  public void setPublisherElementTypeExpression(Expression publisherElementTypeExpression)

  実行時にリクエストメッセージに対してリクエスト Publisher 要素型を評価するように SpEL 式を構成します。

  パラメーター:

  publisherElementTypeExpression - リクエスト Publisher 要素の型を評価する式。

  関連事項:

  • RSocketRequester.RequestSpec.data(java.lang.Object)

• setExpectedResponseType

  public void setExpectedResponseType(ClassSE<?> expectedResponseType)

  RSocket レスポンスのレスポンス型を指定します。

  パラメーター:

  expectedResponseType - 期待される型。

  関連事項:

  • setExpectedResponseTypeExpression(Expression)
  • RSocketRequester.RetrieveSpec.retrieveMono(java.lang.Class<T>)
  • RSocketRequester.RetrieveSpec.retrieveFlux(java.lang.Class<T>)

• setExpectedResponseTypeExpression

  public void setExpectedResponseTypeExpression(Expression expectedResponseTypeExpression)

  Expression を指定して、RSocket レスポンスの型を判別します。

  パラメーター:

  expectedResponseTypeExpression - 予期されるレスポンス型の式。

  関連事項:

  • RSocketRequester.RetrieveSpec.retrieveMono(java.lang.Class<T>)
  • RSocketRequester.RetrieveSpec.retrieveFlux(java.lang.Class<T>)

• setMetadataExpression

  public void setMetadataExpression(Expression metadataExpression)

  SpEL 式を指定して、RSocket リクエストのメタデータをリクエストメッセージに対して Map<Object, MimeType> として評価します。

  パラメーター:

  metadataExpression - メタデータの式。

• doInit

  protected void doInit()

  オーバーライド:

  クラス AbstractReplyProducingMessageHandler の doInit 

• handleRequestMessage

  protected ObjectSE handleRequestMessage(Message<?> requestMessage)

  クラスからコピーされた説明: AbstractReplyProducingMessageHandler

  サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。戻り値は、メッセージ、MessageBuilder、任意のプレーンオブジェクトです。基本クラスは、これらの開始点のいずれかからの返信メッセージの最終的な作成を処理します。戻り値が null の場合、メッセージフローはここで終了します。

  次で指定:

  クラス AbstractReplyProducingMessageHandler の handleRequestMessage 

  パラメーター:

  requestMessage - リクエストメッセージ。

  戻り値:

  メッセージを処理した結果、または null