RSocketInboundGateway (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.endpoint.AbstractEndpoint
  - - org.springframework.integration.gateway.MessagingGatewaySupport
    - - org.springframework.integration.rsocket.inbound.RSocketInboundGateway

実装されているすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, IntegrationPattern, IntegrationRSocketEndpoint, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, ReactiveMessageHandler
```
public class RSocketInboundGateway
extends MessagingGatewaySupport
implements IntegrationRSocketEndpoint
```
IntegrationRSocketEndpoint の MessagingGatewaySupport 実装。RSocket リクエストの受信エンドポイントを表します。
マッピング登録用に AbstractRSocketConnector で構成できます。または、既存の AbstractRSocketConnector Bean が自動的に検出を実行します。
受信 DataBuffer（単一または Publisher 要素として）は、setRequestElementClass(java.lang.Class<?>) または setRequestElementType(ResolvableType) で構成できるターゲットの予期される型に変換されます。構成されていない場合、ターゲット型は contentType ヘッダーによって決定されます。text の場合、ターゲット型は StringSE、それ以外の場合は - byte[] です。
受信 Publisher は、ペイロードを送信するためにメッセージでそのまま使用されます。そのペイロードを可能な方法で処理することは、ターゲットアプリケーションの責任です。
応答ペイロードは、ペイロードの型または Publisher 要素型に従って Flux にエンコードされます。
導入:
5.2
作成者:
Artem Bilan

ネストされたクラスの要約
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
  IntegrationManagement.ManagementOverrides

フィールドのサマリー
- クラス org.springframework.integration.gateway.MessagingGatewaySupport から継承されたフィールド
  messagingTemplate
- クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
  lifecycleCondition, lifecycleLock
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
  METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
- インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
  DEFAULT_PHASE

コンストラクターの概要

コンストラクター
コンストラクターと説明
`RSocketInboundGateway(StringSE... pathArg)` 提供されたパスパターンに基づいてインスタンス化し、受信 RSocket リクエストに対してこのエンドポイントをマップします。

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`doStart()` サブクラスは、開始動作でこのメソッドを実装する必要があります。
`RSocketInteractionModel[]`	`getInteractionModels()` この `ReactiveMessageHandler` がマップされる `RSocketInteractionModel` を取得します。
`StringSE[]`	`getPath()` このエンドポイントがマップされているパスパターンの配列を取得します。
`reactor.core.publisher.Mono<VoidSE>`	`handleMessage(Message<?> requestMessage)`
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`void`	`setDecodeFluxAsUnit(boolean decodeFluxAsUnit)` 受信 `Flux` を単一ユニットまたは各イベントとして個別にデコードするオプションを構成します。
`void`	`setInteractionModels(RSocketInteractionModel... interactionModelsArg)` このエンドポイントがマップされる `RSocketInteractionModel` のセットを構成します。
`void`	`setRequestElementClass(ClassSE<?> requestElementClass)` 受信 RSocket リクエストコンテンツがエンコーダーによって読み取られるときに生成されるペイロードの型を指定します。
`void`	`setRequestElementType(ResolvableType requestElementType)` 受信 RSocket リクエストコンテンツがコンバーター / エンコーダーによって読み取られるときに生成されるペイロードの型を指定します。
`void`	`setRSocketConnector(AbstractRSocketConnector rsocketConnector)` 明示的なエンドポイントマッピング用の `AbstractRSocketConnector` 参照を提供します。
`void`	`setRSocketStrategies(RSocketStrategies rsocketStrategies)` デフォルトの `RSocketStrategies` の代わりに `RSocketStrategies` を構成します。

クラス org.springframework.integration.gateway.MessagingGatewaySupport から継承されたメソッド
buildErrorMessage, buildSendTimer, destroy, doStop, getComponentType, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getManagedName, getManagedType, getOverrides, getReplyChannel, getRequestChannel, isLoggingEnabled, receive, receive, receiveMessage, receiveMessage, registerMetricsCaptor, registerReplyMessageCorrelatorIfNecessary, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, sendTimer, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setErrorOnTimeout, setLoggingEnabled, setManagedName, setManagedType, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrack

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

- コンストラクターの詳細
  - RSocketInboundGateway
```
public RSocketInboundGateway(StringSE... pathArg)
```
    提供されたパスパターンに基づいてインスタンス化し、受信 RSocket リクエストに対してこのエンドポイントをマップします。
    パラメーター:
    pathArg - 使用するマッピングパターン。
- メソッドの詳細
  - setRSocketStrategies
```
public void setRSocketStrategies(RSocketStrategies rsocketStrategies)
```
    デフォルトの RSocketStrategies の代わりに RSocketStrategies を構成します。注: AbstractRSocketConnector が提供されている場合、その RSocketStrategies が優先されます。
    パラメーター:
    rsocketStrategies - 使用する RSocketStrategies。
    関連事項:
    RSocketStrategies.builder()
  - setRSocketConnector
```
public void setRSocketConnector(AbstractRSocketConnector rsocketConnector)
```
    明示的なエンドポイントマッピング用の AbstractRSocketConnector 参照を提供します。
    パラメーター:
    rsocketConnector - 使用する AbstractRSocketConnector。
  - setInteractionModels
```
public void setInteractionModels(RSocketInteractionModel... interactionModelsArg)
```
    このエンドポイントがマップされる RSocketInteractionModel のセットを構成します。
    パラメーター:
    interactionModelsArg - マッピング用の RSocketInteractionModel。
    導入:
    5.2.2
  - getInteractionModels
```
public RSocketInteractionModel[] getInteractionModels()
```
    インターフェースからコピーされた説明: IntegrationRSocketEndpoint
    この ReactiveMessageHandler がマップされる RSocketInteractionModel を取得します。デフォルトはすべての RSocketInteractionModel です。
    次で指定:
    インターフェース IntegrationRSocketEndpoint の getInteractionModels
    戻り値:
    マッピングのための相互作用モデル。
  - getPath
```
public StringSE[] getPath()
```
    このエンドポイントがマップされているパスパターンの配列を取得します。
    次で指定:
    インターフェース IntegrationRSocketEndpoint の getPath
    戻り値:
    マッピングパス
  - setRequestElementClass
```
public void setRequestElementClass(ClassSE<?> requestElementClass)
```
    受信 RSocket リクエストコンテンツがエンコーダーによって読み取られるときに生成されるペイロードの型を指定します。デフォルトでは、この値は null です。これは、実行時に「テキスト」Content-Type が String になり、他のすべてのデフォルトが byte[].class になることを意味します。
    パラメーター:
    requestElementClass - ペイロード型。
  - setRequestElementType
```
public void setRequestElementType(ResolvableType requestElementType)
```
    受信 RSocket リクエストコンテンツがコンバーター / エンコーダーによって読み取られるときに生成されるペイロードの型を指定します。デフォルトでは、この値は null です。これは、実行時に「テキスト」Content-Type が String になり、他のすべてのデフォルトが byte[].class になることを意味します。
    パラメーター:
    requestElementType - ペイロード型。
  - setDecodeFluxAsUnit
```
public void setDecodeFluxAsUnit(boolean decodeFluxAsUnit)
```
    受信 Flux を単一ユニットまたは各イベントとして個別にデコードするオプションを構成します。Spring メッセージング @MessageMapping との整合性を保つために、デフォルトは false です。ターゲット Flux デコードロジックは、選択した Decoder によって異なります。たとえば、StringDecoder では、バイトバッファの終了を示すために、ストリームに改行文字が存在する必要があります。
    パラメーター:
    decodeFluxAsUnit - 受信 Flux を単一ユニットまたは各イベントとして個別にデコードします。
    導入:
    5.3
    関連事項:
    Decoder.decode(Publisher, ResolvableType, MimeType, java.util.Map)
  - onInit
```
protected void onInit()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスは、初期化ロジック用にこれを実装できます。
    オーバーライド:
    クラス MessagingGatewaySupport の onInit
  - doStart
```
protected void doStart()
```
    クラスからコピーされた説明: AbstractEndpoint
    サブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
    オーバーライド:
    クラス MessagingGatewaySupport の doStart
  - handleMessage
```
public reactor.core.publisher.Mono<VoidSE> handleMessage(Message<?> requestMessage)
```
    次で指定:
    インターフェース ReactiveMessageHandler の handleMessage

クラス RSocketInboundGateway

ネストされたクラスの要約

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.gateway.MessagingGatewaySupport から継承されたフィールド

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.gateway.MessagingGatewaySupport から継承されたメソッド

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

RSocketInboundGateway

メソッドの詳細

setRSocketStrategies

setRSocketConnector

setInteractionModels

getInteractionModels

getPath

setRequestElementClass

setRequestElementType

setDecodeFluxAsUnit

onInit

doStart

handleMessage