Class ClientRSocketConnector
java.lang.Object
org.springframework.integration.rsocket.AbstractRSocketConnector
org.springframework.integration.rsocket.ClientRSocketConnector
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.beans.factory.SmartInitializingSingleton,org.springframework.context.ApplicationContextAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class ClientRSocketConnector extends AbstractRSocketConnector
A client
AbstractRSocketConnector extension to the RSocket connection.- Since:
- 5.2
- See Also:
RSocketConnector,RSocketRequester
-
Field Summary
Fields inherited from class org.springframework.integration.rsocket.AbstractRSocketConnector
rSocketMessageHandler -
Constructor Summary
Constructors Constructor Description ClientRSocketConnector(io.rsocket.transport.ClientTransport clientTransport)Instantiate a connector based on the providedClientTransport.ClientRSocketConnector(java.lang.String host, int port)Instantiate a connector based on theTcpClientTransport.ClientRSocketConnector(java.net.URI uri)Instantiate a connector based on theWebsocketClientTransport. -
Method Summary
Modifier and Type Method Description voidafterPropertiesSet()voidafterSingletonsInstantiated()voidconnect()Perform subscription into the RSocket server for incoming requests.voiddestroy()protected voiddoStart()org.springframework.messaging.rsocket.RSocketRequestergetRequester()Return theRSocketRequesterthis connector is built on.reactor.core.publisher.Mono<org.springframework.messaging.rsocket.RSocketRequester>getRSocketRequester()Deprecated.since 5.4 in favor ofgetRequester()voidsetConnectorConfigurer(org.springframework.messaging.rsocket.RSocketConnectorConfigurer connectorConfigurer)Callback to configure theClientRSocketFactorydirectly.voidsetSetupData(java.lang.Object setupData)Set the data for the setup payload.voidsetSetupMetadata(java.util.Map<java.lang.Object,org.springframework.util.MimeType> setupMetadata)Add metadata to the setup payload.voidsetSetupRoute(java.lang.String setupRoute)Set the route for the setup payload.voidsetSetupRouteVariables(java.lang.Object... setupRouteVars)Set the variables for route template to expand with.Methods inherited from class org.springframework.integration.rsocket.AbstractRSocketConnector
addEndpoint, getDataMimeType, getMetadataMimeType, getRSocketStrategies, isAutoStartup, isRunning, setApplicationContext, setAutoStartup, setDataMimeType, setEndpoints, setMetadataMimeType, setRSocketStrategies, start, stop
-
Constructor Details
-
ClientRSocketConnector
public ClientRSocketConnector(java.lang.String host, int port)Instantiate a connector based on theTcpClientTransport.- Parameters:
host- the TCP host to connect.port- the TCP port to connect.- See Also:
ClientRSocketConnector(ClientTransport)
-
ClientRSocketConnector
public ClientRSocketConnector(java.net.URI uri)Instantiate a connector based on theWebsocketClientTransport.- Parameters:
uri- the WebSocket URI to connect.- See Also:
ClientRSocketConnector(ClientTransport)
-
ClientRSocketConnector
public ClientRSocketConnector(io.rsocket.transport.ClientTransport clientTransport)Instantiate a connector based on the providedClientTransport.- Parameters:
clientTransport- theClientTransportto use.- See Also:
RSocketRequester.Builder.transport(ClientTransport)
-
-
Method Details
-
setConnectorConfigurer
public void setConnectorConfigurer(org.springframework.messaging.rsocket.RSocketConnectorConfigurer connectorConfigurer)Callback to configure theClientRSocketFactorydirectly. Note: this class adds extraRSocketConnectorConfigurerto the targetRSocketRequesterto populate a reference to an internalRSocketMessageHandler.responder(). This overrides possible externalRSocketConnector.acceptor(io.rsocket.SocketAcceptor)- Parameters:
connectorConfigurer- theRSocketConnectorConfigurerto configure theRSocketConnector.- Since:
- 5.2.6
- See Also:
RSocketRequester.Builder.rsocketConnector(RSocketConnectorConfigurer)
-
setSetupRoute
public void setSetupRoute(java.lang.String setupRoute)Set the route for the setup payload.- Parameters:
setupRoute- the route to connect to.- See Also:
RSocketRequester.Builder.setupRoute(String, Object...)
-
setSetupRouteVariables
public void setSetupRouteVariables(java.lang.Object... setupRouteVars)Set the variables for route template to expand with.- Parameters:
setupRouteVars- the route to connect to.- See Also:
RSocketRequester.Builder.setupRoute(String, Object...)
-
setSetupMetadata
public void setSetupMetadata(java.util.Map<java.lang.Object,org.springframework.util.MimeType> setupMetadata)Add metadata to the setup payload. Composite metadata must be in use if this is called more than once or in addition tosetSetupRoute(String).- Parameters:
setupMetadata- the map of metadata to use.- See Also:
RSocketRequester.Builder.setupMetadata(Object, MimeType)
-
setSetupData
public void setSetupData(java.lang.Object setupData)Set the data for the setup payload.- Parameters:
setupData- the data for connect frame.- See Also:
RSocketRequester.Builder.setupData(Object)
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceorg.springframework.beans.factory.InitializingBean- Overrides:
afterPropertiesSetin classAbstractRSocketConnector
-
afterSingletonsInstantiated
public void afterSingletonsInstantiated()- Specified by:
afterSingletonsInstantiatedin interfaceorg.springframework.beans.factory.SmartInitializingSingleton- Overrides:
afterSingletonsInstantiatedin classAbstractRSocketConnector
-
doStart
protected void doStart()- Specified by:
doStartin classAbstractRSocketConnector
-
destroy
public void destroy() -
connect
public void connect()Perform subscription into the RSocket server for incoming requests. -
getRSocketRequester
@Deprecated public reactor.core.publisher.Mono<org.springframework.messaging.rsocket.RSocketRequester> getRSocketRequester()Deprecated.since 5.4 in favor ofgetRequester()Return theMonofor theRSocketRequester.- Returns:
- the
Monofor theRSocketRequester.
-
getRequester
public org.springframework.messaging.rsocket.RSocketRequester getRequester()Return theRSocketRequesterthis connector is built on.- Returns:
- the
RSocketRequesterthis connector is built on. - Since:
- 5.4
-