public class ClientRSocketConnector extends AbstractRSocketConnector
AbstractRSocketConnector
拡張。RSocketConnector
, RSocketRequester
rSocketMessageHandler
DEFAULT_PHASE
コンストラクターと説明 |
---|
ClientRSocketConnector(io.rsocket.transport.ClientTransport clientTransport) 提供された ClientTransport に基づいてコネクターをインスタンス化します。 |
ClientRSocketConnector(StringSE host, int port) TcpClientTransport に基づいてコネクターをインスタンス化します。 |
ClientRSocketConnector(URISE uri) WebsocketClientTransport に基づいてコネクターをインスタンス化します。 |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() |
void | afterSingletonsInstantiated() |
void | connect() 受信リクエストのために RSocket サーバーへのサブスクリプションを実行します。 |
void | destroy() |
protected void | doStart() |
RSocketRequester | getRequester() このコネクターが組み込まれている RSocketRequester を返します。 |
reactor.core.publisher.Mono<RSocketRequester> | getRSocketRequester() 使用すべきではありません。 5.4 以降、 getRequester() を推奨 |
void | setConnectorConfigurer(RSocketConnectorConfigurer connectorConfigurer) ClientRSocketFactory を直接構成するためのコールバック。 |
void | setSetupData(ObjectSE setupData) 設定ペイロードのデータを設定します。 |
void | setSetupMetadata(MapSE<ObjectSE, MimeType> setupMetadata) セットアップペイロードにメタデータを追加します。 |
void | setSetupRoute(StringSE setupRoute) セットアップペイロードのルートを設定します。 |
void | setSetupRouteVariables(ObjectSE... setupRouteVars) 展開するルートテンプレートの変数を設定します。 |
addEndpoint, getDataMimeType, getMetadataMimeType, getRSocketStrategies, isAutoStartup, isRunning, setApplicationContext, setAutoStartup, setDataMimeType, setEndpoints, setMetadataMimeType, setRSocketStrategies, start, stop
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
getPhase, stop
public ClientRSocketConnector(StringSE host, int port)
TcpClientTransport
に基づいてコネクターをインスタンス化します。host
- 接続する TCP ホスト。port
- 接続する TCP ポート。ClientRSocketConnector(ClientTransport)
public ClientRSocketConnector(URISE uri)
WebsocketClientTransport
に基づいてコネクターをインスタンス化します。uri
- 接続する WebSocket URI。ClientRSocketConnector(ClientTransport)
public ClientRSocketConnector(io.rsocket.transport.ClientTransport clientTransport)
ClientTransport
に基づいてコネクターをインスタンス化します。clientTransport
- 使用する ClientTransport
。RSocketRequester.Builder#transport(ClientTransport)
public void setConnectorConfigurer(RSocketConnectorConfigurer connectorConfigurer)
ClientRSocketFactory
を直接構成するためのコールバック。注: このクラスは、ターゲット RSocketRequester
に追加の RSocketConnectorConfigurer
を追加して、内部 RSocketMessageHandler.responder()
への参照を設定します。これは可能な外部 RSocketConnector.acceptor(io.rsocket.SocketAcceptor)
を上書きします connectorConfigurer
- RSocketConnector
を構成する RSocketConnectorConfigurer
。RSocketRequester.Builder#rsocketConnector(RSocketConnectorConfigurer)
public void setSetupRoute(StringSE setupRoute)
setupRoute
- 接続するルート RSocketRequester.Builder#setupRoute(String, Object...)
public void setSetupRouteVariables(ObjectSE... setupRouteVars)
setupRouteVars
- 接続するルート RSocketRequester.Builder#setupRoute(String, Object...)
public void setSetupMetadata(MapSE<ObjectSE,MimeType> setupMetadata)
setSetupRoute(String)
に加えて呼び出される場合は、複合メタデータを使用する必要があります。setupMetadata
- 使用するメタデータのマップ。RSocketRequester.Builder#setupMetadata(Object, MimeType)
public void setSetupData(ObjectSE setupData)
setupData
- 接続フレームのデータ。RSocketRequester.Builder#setupData(Object)
public void afterPropertiesSet()
InitializingBean
の afterPropertiesSet
AbstractRSocketConnector
の afterPropertiesSet
public void afterSingletonsInstantiated()
SmartInitializingSingleton
の afterSingletonsInstantiated
AbstractRSocketConnector
の afterSingletonsInstantiated
protected void doStart()
AbstractRSocketConnector
の doStart
public void destroy()
public void connect()
@DeprecatedSE public reactor.core.publisher.Mono<RSocketRequester> getRSocketRequester()
getRequester()
に移行 RSocketRequester
の Mono
を返します。RSocketRequester
の Mono
。public RSocketRequester getRequester()
RSocketRequester
を返します。RSocketRequester
。