Package org.springframework.boot.rsocket.netty

Class NettyRSocketServer

java.lang.Object

org.springframework.boot.rsocket.netty.NettyRSocketServer

All Implemented Interfaces:

RSocketServer

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.

Since:

2.2.0

Author:

Brian Clozel

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