Package | Description |
---|---|
org.springframework.messaging.simp.stomp |
Generic support for simple messaging protocols (like STOMP).
|
org.springframework.messaging.tcp.reactor |
Contains support for TCP messaging based on Reactor.
|
Modifier and Type | Class and Description |
---|---|
class |
StompReactorNettyCodec
Simple delegation to StompDecoder and StompEncoder.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractNioBufferReactorNettyCodec<P>
Convenient base class for
ReactorNettyCodec implementations that need
to work with NIO ByteBuffers . |
Constructor and Description |
---|
ReactorNettyTcpClient(Function<reactor.netty.tcp.TcpClient,reactor.netty.tcp.TcpClient> clientConfigurer,
ReactorNettyCodec<P> codec)
A variant of
ReactorNettyTcpClient(String, int, ReactorNettyCodec)
that still manages the lifecycle of the TcpClient and underlying
resources, but allows for direct configuration of other properties of the
client through a Function<TcpClient, TcpClient> . |
ReactorNettyTcpClient(String host,
int port,
ReactorNettyCodec<P> codec)
Simple constructor with the host and port to use to connect to.
|
ReactorNettyTcpClient(reactor.netty.tcp.TcpClient tcpClient,
ReactorNettyCodec<P> codec)
Constructor with an externally created
TcpClient instance whose
lifecycle is expected to be managed externally. |
ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound,
reactor.netty.NettyOutbound outbound,
ReactorNettyCodec<P> codec,
reactor.core.publisher.DirectProcessor<Void> closeProcessor) |