public class NettyRSocketServerFactory extends java.lang.Object implements RSocketServerFactory, ConfigurableRSocketServerFactory
RSocketServerFactory
that can be used to create RSocketServer
s backed
by Netty.Constructor and Description |
---|
NettyRSocketServerFactory() |
Modifier and Type | Method and Description |
---|---|
void |
addRSocketServerCustomizers(RSocketServerCustomizer... rSocketServerCustomizers)
Add
RSocketServerCustomizer s that should be called to configure the
RSocketServer . |
NettyRSocketServer |
create(io.rsocket.SocketAcceptor socketAcceptor)
Gets a new fully configured but paused
RSocketServer instance. |
void |
setAddress(java.net.InetAddress address)
Set the specific network address that the server should bind to.
|
void |
setFragmentSize(org.springframework.util.unit.DataSize fragmentSize)
Specify the maximum transmission unit.
|
void |
setLifecycleTimeout(java.time.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(org.springframework.http.client.reactive.ReactorResourceFactory resourceFactory)
Set the
ReactorResourceFactory to get the shared resources from. |
void |
setRSocketServerCustomizers(java.util.Collection<? extends RSocketServerCustomizer> rSocketServerCustomizers)
Set
RSocketServerCustomizer s that should be called to configure the
RSocketServer while building the server. |
void |
setSsl(Ssl ssl)
Sets the SSL configuration that will be applied to the server's default connector.
|
void |
setSslStoreProvider(SslStoreProvider sslStoreProvider)
Sets a provider that will be used to obtain SSL stores.
|
void |
setTransport(RSocketServer.Transport transport)
Set the transport that the RSocket server should use.
|
public void setPort(int port)
ConfigurableRSocketServerFactory
setPort
in interface ConfigurableRSocketServerFactory
port
- the port to setpublic void setFragmentSize(org.springframework.util.unit.DataSize fragmentSize)
ConfigurableRSocketServerFactory
fragmentSize
are fragmented.setFragmentSize
in interface ConfigurableRSocketServerFactory
fragmentSize
- the fragment sizepublic void setAddress(java.net.InetAddress address)
ConfigurableRSocketServerFactory
setAddress
in interface ConfigurableRSocketServerFactory
address
- the address to set (defaults to null
)public void setTransport(RSocketServer.Transport transport)
ConfigurableRSocketServerFactory
setTransport
in interface ConfigurableRSocketServerFactory
transport
- the transport protocol to usepublic void setSsl(Ssl ssl)
ConfigurableRSocketServerFactory
setSsl
in interface ConfigurableRSocketServerFactory
ssl
- the SSL configurationpublic void setSslStoreProvider(SslStoreProvider sslStoreProvider)
ConfigurableRSocketServerFactory
setSslStoreProvider
in interface ConfigurableRSocketServerFactory
sslStoreProvider
- the SSL store providerpublic void setResourceFactory(org.springframework.http.client.reactive.ReactorResourceFactory resourceFactory)
ReactorResourceFactory
to get the shared resources from.resourceFactory
- the server resourcespublic void setRSocketServerCustomizers(java.util.Collection<? extends RSocketServerCustomizer> rSocketServerCustomizers)
RSocketServerCustomizer
s that should be called to configure the
RSocketServer
while building the server. Calling this
method will replace any existing customizers.rSocketServerCustomizers
- customizers to apply before the server startspublic void addRSocketServerCustomizers(RSocketServerCustomizer... rSocketServerCustomizers)
RSocketServerCustomizer
s that should be called to configure the
RSocketServer
.rSocketServerCustomizers
- customizers to apply before the server startspublic void setLifecycleTimeout(java.time.Duration lifecycleTimeout)
lifecycleTimeout
- the lifecycle timeoutpublic NettyRSocketServer create(io.rsocket.SocketAcceptor socketAcceptor)
RSocketServerFactory
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).create
in interface RSocketServerFactory
socketAcceptor
- the socket acceptorRSocketServer
RSocketServer.stop()