org.springframework.integration.rsocket

Class ClientRSocketConnector

java.lang.Object

org.springframework.integration.rsocket.AbstractRSocketConnector

org.springframework.integration.rsocket.ClientRSocketConnector

All Implemented Interfaces:

Aware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle

public class ClientRSocketConnector
extends AbstractRSocketConnector

A client AbstractRSocketConnector extension to the RSocket server.

Note: the RSocketFactory.ClientRSocketFactory#acceptor(java.util.function.Function) in the provided factoryConfigurer is overridden with an internal IntegrationRSocketAcceptor for the proper Spring Integration channel adapter mappings.

Since:

5.2

Author:

Artem Bilan

See Also:

RSocketFactory.ClientRSocketFactory, RSocketRequester

Field Summary

Fields inherited from class org.springframework.integration.rsocket.AbstractRSocketConnector

rsocketAcceptor

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
ClientRSocketConnector(io.rsocket.transport.ClientTransport clientTransport) Instantiate a connector based on the provided ClientTransport.
ClientRSocketConnector(String host, int port) Instantiate a connector based on the TcpClientTransport.
ClientRSocketConnector(URI uri) Instantiate a connector based on the WebsocketClientTransport.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	afterSingletonsInstantiated()
void	connect() Perform subscription into the RSocket server for incoming requests.
void	destroy()
protected void	doStart()
reactor.core.publisher.Mono<org.springframework.messaging.rsocket.RSocketRequester>	getRSocketRequester()
void	setConnectData(String connectData) Configure a data for connect.
void	setConnectRoute(String connectRoute) Configure a route for server RSocket endpoint.
void	setFactoryConfigurer(java.util.function.Consumer<io.rsocket.RSocketFactory.ClientRSocketFactory> factoryConfigurer) Specify a Consumer for configuring a RSocketFactory.ClientRSocketFactory.

Methods inherited from class org.springframework.integration.rsocket.AbstractRSocketConnector

addEndpoint, getDataMimeType, getRSocketStrategies, isRunning, setApplicationContext, setDataMimeType, setEndpoints, setRSocketStrategies, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, isAutoStartup, stop

Constructor Detail

ClientRSocketConnector

public ClientRSocketConnector(String host,
                              int port)

Instantiate a connector based on the TcpClientTransport.

Parameters:

host - the TCP host to connect.

port - the TCP port to connect.

See Also:

ClientRSocketConnector(ClientTransport)

ClientRSocketConnector

public ClientRSocketConnector(URI uri)

Instantiate a connector based on the WebsocketClientTransport.

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 provided ClientTransport.

Parameters:

clientTransport - the ClientTransport to use.

Method Detail

setFactoryConfigurer

public void setFactoryConfigurer(java.util.function.Consumer<io.rsocket.RSocketFactory.ClientRSocketFactory> factoryConfigurer)

Specify a Consumer for configuring a RSocketFactory.ClientRSocketFactory.

Parameters:

factoryConfigurer - the Consumer to configure the RSocketFactory.ClientRSocketFactory.

setConnectRoute

public void setConnectRoute(String connectRoute)

Configure a route for server RSocket endpoint.

Parameters:

connectRoute - the route to connect to.

setConnectData

public void setConnectData(String connectData)

Configure a data for connect. Defaults to empty string.

Parameters:

connectData - the data for connect frame.

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

Overrides:

afterPropertiesSet in class AbstractRSocketConnector

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

Overrides:

afterSingletonsInstantiated in class AbstractRSocketConnector

doStart

protected void doStart()

Specified by:

doStart in class AbstractRSocketConnector

destroy

public void destroy()

connect

public void connect()

Perform subscription into the RSocket server for incoming requests.

getRSocketRequester

public reactor.core.publisher.Mono<org.springframework.messaging.rsocket.RSocketRequester> getRSocketRequester()