org.springframework.boot.rsocket.netty

Class NettyRSocketServerFactory

java.lang.Object

org.springframework.boot.rsocket.netty.NettyRSocketServerFactory

All Implemented Interfaces:

ConfigurableRSocketServerFactory, RSocketServerFactory

public class NettyRSocketServerFactory
extends Object
implements RSocketServerFactory, ConfigurableRSocketServerFactory

RSocketServerFactory that can be used to create RSocketServers backed by Netty.

Since:

2.2.0

Author:

Brian Clozel

Constructor Summary

Constructors

Constructor and Description
NettyRSocketServerFactory()

Method Summary

Modifier and Type	Method and Description
void	addServerCustomizers(ServerRSocketFactoryCustomizer... serverCustomizers) Add ServerRSocketFactoryCustomizers that should applied while building the server.
NettyRSocketServer	create(io.rsocket.SocketAcceptor socketAcceptor) Gets a new fully configured but paused RSocketServer instance.
void	setAddress(InetAddress address) Set the specific network address that the server should bind to.
void	setLifecycleTimeout(Duration lifecycleTimeout) Set the maximum amount of time that should be waited when starting or stopping the server.
void	setPort(int port) Set the port that the server should listen on.
void	setResourceFactory(ReactorResourceFactory resourceFactory) Set the ReactorResourceFactory to get the shared resources from.
void	setServerCustomizers(Collection<? extends ServerRSocketFactoryCustomizer> serverCustomizers) Set ServerRSocketFactoryCustomizers that should be applied to the RSocket server builder.
void	setTransport(RSocketServer.TRANSPORT transport) Set the transport that the RSocket server should use.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyRSocketServerFactory

public NettyRSocketServerFactory()

Method Detail

setPort

public void setPort(int port)

Description copied from interface: ConfigurableRSocketServerFactory

Set the port that the server should listen on. If not specified port '9898' will be used.

Specified by:

setPort in interface ConfigurableRSocketServerFactory

Parameters:

port - the port to set

setAddress

public void setAddress(InetAddress address)

Description copied from interface: ConfigurableRSocketServerFactory

Set the specific network address that the server should bind to.

Specified by:

setAddress in interface ConfigurableRSocketServerFactory

Parameters:

address - the address to set (defaults to null)

setTransport

public void setTransport(RSocketServer.TRANSPORT transport)

Description copied from interface: ConfigurableRSocketServerFactory

Set the transport that the RSocket server should use.

Specified by:

setTransport in interface ConfigurableRSocketServerFactory

Parameters:

transport - the transport protocol to use

setResourceFactory

public void setResourceFactory(ReactorResourceFactory resourceFactory)

Set the ReactorResourceFactory to get the shared resources from.

Parameters:

resourceFactory - the server resources

setServerCustomizers

public void setServerCustomizers(Collection<? extends ServerRSocketFactoryCustomizer> serverCustomizers)

Set ServerRSocketFactoryCustomizers that should be applied to the RSocket server builder. Calling this method will replace any existing customizers.

Parameters:

serverCustomizers - the customizers to set

addServerCustomizers

public void addServerCustomizers(ServerRSocketFactoryCustomizer... serverCustomizers)

Add ServerRSocketFactoryCustomizers that should applied while building the server.

Parameters:

serverCustomizers - the customizers to add

setLifecycleTimeout

public void setLifecycleTimeout(Duration lifecycleTimeout)

Set the maximum amount of time that should be waited when starting or stopping the server.

Parameters:

lifecycleTimeout - the lifecycle timeout

create

public NettyRSocketServer create(io.rsocket.SocketAcceptor socketAcceptor)

Description copied from interface: RSocketServerFactory

Gets a new fully configured but paused RSocketServer instance. Clients should not be able to connect to the returned server until RSocketServer.start() is called (which happens when the ApplicationContext has been fully refreshed).

Specified by:

create in interface RSocketServerFactory

Parameters:

socketAcceptor - the socket acceptor

Returns:

a fully configured and started RSocketServer

See Also:

RSocketServer.stop()