org.springframework.integration.rsocket

Class ServerRSocketConnector

java.lang.Object

org.springframework.integration.rsocket.AbstractRSocketConnector

org.springframework.integration.rsocket.ServerRSocketConnector

All Implemented Interfaces:

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

public class ServerRSocketConnector
extends AbstractRSocketConnector
implements ApplicationEventPublisherAware

A server AbstractRSocketConnector extension to accept and manage client RSocket connections.

Note: the RSocketFactory.ServerRSocketFactory#acceptor(SocketAcceptor) 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.ServerRSocketFactory

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
ServerRSocketConnector(reactor.netty.http.server.HttpServer server) Instantiate a server connector based on the WebsocketServerTransport.
ServerRSocketConnector(io.rsocket.transport.ServerTransport<? extends io.rsocket.Closeable> serverTransport) Instantiate a server connector based on the provided ServerTransport.
ServerRSocketConnector(String bindAddress, int port) Instantiate a server connector based on the TcpServerTransport.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
protected void	doStart()
org.springframework.messaging.rsocket.RSocketRequester	getClientRSocketRequester(Object key)
Map<Object,org.springframework.messaging.rsocket.RSocketRequester>	getClientRSocketRequesters()
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setClientRSocketKeyStrategy(java.util.function.BiFunction<String,DataBuffer,Object> clientRSocketKeyStrategy) Configure a strategy to determine a key for the client RSocketRequester connected.
void	setFactoryConfigurer(java.util.function.Consumer<io.rsocket.RSocketFactory.ServerRSocketFactory> factoryConfigurer) Provide a Consumer to configure the RSocketFactory.ServerRSocketFactory.

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

addEndpoint, afterSingletonsInstantiated, 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

ServerRSocketConnector

public ServerRSocketConnector(String bindAddress,
                              int port)

Instantiate a server connector based on the TcpServerTransport.

Parameters:

bindAddress - the local address to bind TCP server onto.

port - the local TCP port to bind.

See Also:

ServerRSocketConnector(ServerTransport)

ServerRSocketConnector

public ServerRSocketConnector(reactor.netty.http.server.HttpServer server)

Instantiate a server connector based on the WebsocketServerTransport.

Parameters:

server - the HttpServer to use.

See Also:

ServerRSocketConnector(ServerTransport)

ServerRSocketConnector

public ServerRSocketConnector(io.rsocket.transport.ServerTransport<? extends io.rsocket.Closeable> serverTransport)

Instantiate a server connector based on the provided ServerTransport.

Parameters:

serverTransport - the ServerTransport to make server based on.

Method Detail

setFactoryConfigurer

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

Provide a Consumer to configure the RSocketFactory.ServerRSocketFactory.

Parameters:

factoryConfigurer - the Consumer to configure the RSocketFactory.ServerRSocketFactory.

setClientRSocketKeyStrategy

public void setClientRSocketKeyStrategy(java.util.function.BiFunction<String,DataBuffer,Object> clientRSocketKeyStrategy)

Configure a strategy to determine a key for the client RSocketRequester connected. Defaults to the destination the client is connected.

Parameters:

clientRSocketKeyStrategy - the BiFunction to determine a key for client RSocketRequesters.

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

Overrides:

afterPropertiesSet in class AbstractRSocketConnector

getClientRSocketRequesters

public Map<Object,org.springframework.messaging.rsocket.RSocketRequester> getClientRSocketRequesters()

getClientRSocketRequester

@Nullable
public org.springframework.messaging.rsocket.RSocketRequester getClientRSocketRequester(Object key)

doStart

protected void doStart()

Specified by:

doStart in class AbstractRSocketConnector

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean