NettyRSocketServer (spring-boot 3.1.4)

org.springframework.boot.rsocket.netty.NettyRSocketServer

public class NettyRSocketServer extends Object implements RSocketServer

RSocketServer that is based on a Reactor Netty server. Usually this class should be created using the NettyRSocketServerFactory and not directly.

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.boot.rsocket.server.RSocketServer
RSocketServer.Transport
Constructor Summary

Constructors

Constructor

Description

NettyRSocketServer(reactor.core.publisher.Mono<io.rsocket.transport.netty.server.CloseableChannel> starter, Duration lifecycleTimeout)
Method Summary

Modifier and Type

Method

Description

InetSocketAddress

address()

Return the address this server is listening on.

void

start()

Starts the RSocket server.

void

stop()

Stops the RSocket server.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- NettyRSocketServer
  
  public NettyRSocketServer(reactor.core.publisher.Mono<io.rsocket.transport.netty.server.CloseableChannel> starter, Duration lifecycleTimeout)
Method Details
- address
  
  public InetSocketAddress address()
  
  Description copied from interface: RSocketServer
  
  Return the address this server is listening on.
  
  Specified by:
  
  address in interface RSocketServer
  
  Returns:
  
  the address
- start
  
  public void start() throws RSocketServerException
  
  Description copied from interface: RSocketServer
  
  Starts the RSocket server. Calling this method on an already started server has no effect.
  
  Specified by:
  
  start in interface RSocketServer
  
  Throws:
  
  RSocketServerException - if the server cannot be started
- stop
  
  public void stop() throws RSocketServerException
  
  Description copied from interface: RSocketServer
  
  Stops the RSocket server. Calling this method on an already stopped server has no effect.
  
  Specified by:
  
  stop in interface RSocketServer
  
  Throws:
  
  RSocketServerException - if the server cannot be stopped

Class NettyRSocketServer