クラス ClientRSocketConnector
java.lang.ObjectSE
org.springframework.integration.rsocket.AbstractRSocketConnector
org.springframework.integration.rsocket.ClientRSocketConnector
- 実装されたすべてのインターフェース:
Aware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle
RSocket 接続のクライアント
AbstractRSocketConnector 拡張。- 導入:
- 5.2
- 作成者:
- Artem Bilan
- 関連事項:
RSocketConnectorRSocketRequester
フィールドサマリー
クラス org.springframework.integration.rsocket.AbstractRSocketConnector から継承されたフィールド
rSocketMessageHandlerインターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクターのサマリー
コンストラクターコンストラクター説明ClientRSocketConnector(io.rsocket.transport.ClientTransport clientTransport) 提供されたClientTransportに基づいてコネクターをインスタンス化します。ClientRSocketConnector(StringSE host, int port) TcpClientTransportに基づいてコネクターをインスタンス化します。WebsocketClientTransportに基づいてコネクターをインスタンス化します。メソッドのサマリー
修飾子と型メソッド説明voidvoidvoidconnect()受信リクエストのために RSocket サーバーへのサブスクリプションを実行します。voiddestroy()protected voiddoStart()このコネクターが組み込まれているRSocketRequesterを返します。voidsetConnectorConfigurer(RSocketConnectorConfigurer connectorConfigurer) ClientRSocketFactoryを直接構成するためのコールバック。voidsetSetupData(ObjectSE setupData) 設定ペイロードのデータを設定します。voidsetSetupMetadata(MapSE<ObjectSE, MimeType> setupMetadata) セットアップペイロードにメタデータを追加します。voidsetSetupRoute(StringSE setupRoute) セットアップペイロードのルートを設定します。voidsetSetupRouteVariables(ObjectSE... setupRouteVars) 展開するルートテンプレートの変数を設定します。クラス org.springframework.integration.rsocket.AbstractRSocketConnector から継承されたメソッド
addEndpoint, getDataMimeType, getMetadataMimeType, getRSocketStrategies, isAutoStartup, isRunning, setApplicationContext, setAutoStartup, setDataMimeType, setEndpoints, setMetadataMimeType, setRSocketStrategies, start, stopクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.context.SmartLifecycle から継承されたメソッド
getPhase, stop
コンストラクターの詳細
ClientRSocketConnector
TcpClientTransportに基づいてコネクターをインスタンス化します。- パラメーター:
host- 接続する TCP ホスト。port- 接続する TCP ポート。- 関連事項:
ClientRSocketConnector
WebsocketClientTransportに基づいてコネクターをインスタンス化します。- パラメーター:
uri- 接続する WebSocket URI。- 関連事項:
ClientRSocketConnector
public ClientRSocketConnector(io.rsocket.transport.ClientTransport clientTransport) 提供されたClientTransportに基づいてコネクターをインスタンス化します。- パラメーター:
clientTransport- 使用するClientTransport。- 関連事項:
メソッドの詳細
setConnectorConfigurer
ClientRSocketFactoryを直接構成するためのコールバック。注: このクラスは、ターゲットRSocketRequesterに追加のRSocketConnectorConfigurerを追加して、内部RSocketMessageHandler.responder()への参照を設定します。これは可能な外部RSocketConnector.acceptor(io.rsocket.SocketAcceptor)を上書きします- パラメーター:
connectorConfigurer-RSocketConnectorを構成するRSocketConnectorConfigurer。- 導入:
- 5.2.6
- 関連事項:
setSetupRoute
セットアップペイロードのルートを設定します。- パラメーター:
setupRoute- 接続するルート- 関連事項:
setSetupRouteVariables
展開するルートテンプレートの変数を設定します。- パラメーター:
setupRouteVars- 接続するルート- 関連事項:
setSetupMetadata
セットアップペイロードにメタデータを追加します。これが複数回呼び出される場合、またはsetSetupRoute(String)に加えて呼び出される場合は、複合メタデータを使用する必要があります。- パラメーター:
setupMetadata- 使用するメタデータのマップ。- 関連事項:
setSetupData
設定ペイロードのデータを設定します。- パラメーター:
setupData- 接続フレームのデータ。- 関連事項:
afterPropertiesSet
public void afterPropertiesSet()- 次で指定:
- インターフェース
InitializingBeanのafterPropertiesSet - オーバーライド:
- クラス
AbstractRSocketConnectorのafterPropertiesSet
afterSingletonsInstantiated
public void afterSingletonsInstantiated()- 次で指定:
- インターフェース
SmartInitializingSingletonのafterSingletonsInstantiated - オーバーライド:
- クラス
AbstractRSocketConnectorのafterSingletonsInstantiated
doStart
protected void doStart()- 次で指定:
- クラス
AbstractRSocketConnectorのdoStart
destroy
public void destroy()connect
public void connect()受信リクエストのために RSocket サーバーへのサブスクリプションを実行します。getRequester
このコネクターが組み込まれているRSocketRequesterを返します。- 戻り値:
- このコネクターが組み込まれている
RSocketRequester。 - 導入:
- 5.4