Uses of Interface
org.springframework.messaging.tcp.reactor.ReactorNettyCodec
Packages that use ReactorNettyCodec 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.Uses of ReactorNettyCodec in org.springframework.messaging.simp.stomp
Classes in org.springframework.messaging.simp.stomp that implement ReactorNettyCodec Modifier and Type Class Description class
StompReactorNettyCodec
Simple delegation to StompDecoder and StompEncoder.Uses of ReactorNettyCodec in org.springframework.messaging.tcp.reactor
Classes in org.springframework.messaging.tcp.reactor that implement ReactorNettyCodec Modifier and Type Class Description class
AbstractNioBufferReactorNettyCodec<P>
Convenient base class forReactorNettyCodec
implementations that need to work with NIOByteBuffers
.Constructors in org.springframework.messaging.tcp.reactor with parameters of type ReactorNettyCodec Constructor Description ReactorNettyTcpClient(String host, int port, ReactorNettyCodec<P> codec)
Simple constructor with the host and port to use to connect to.ReactorNettyTcpClient(Function<reactor.netty.tcp.TcpClient,reactor.netty.tcp.TcpClient> clientConfigurer, ReactorNettyCodec<P> codec)
A variant ofReactorNettyTcpClient(String, int, ReactorNettyCodec)
that still manages the lifecycle of theTcpClient
and underlying resources, but allows for direct configuration of other properties of the client through aFunction<TcpClient, TcpClient>
.ReactorNettyTcpClient(reactor.netty.tcp.TcpClient tcpClient, ReactorNettyCodec<P> codec)
Constructor with an externally createdTcpClient
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)