Class AbstractNioBufferReactorNettyCodec<P>
java.lang.Object
org.springframework.messaging.tcp.reactor.AbstractNioBufferReactorNettyCodec<P>
- Type Parameters:
P
- the message payload type
- All Implemented Interfaces:
ReactorNettyCodec<P>
- Direct Known Subclasses:
StompReactorNettyCodec
public abstract class AbstractNioBufferReactorNettyCodec<P>
extends Object
implements ReactorNettyCodec<P>
Convenient base class for
ReactorNettyCodec
implementations that need
to work with NIO ByteBuffers
.- Since:
- 5.0
- Author:
- Rossen Stoyanchev
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptiondecode
(io.netty.buffer.ByteBuf inputBuffer) Decode the inputByteBuf
into one or moreMessages
.decodeInternal
(ByteBuffer nioBuffer) void
Encode the givenMessage
to the outputByteBuf
.protected abstract ByteBuffer
encodeInternal
(Message<P> message)
-
Constructor Details
-
AbstractNioBufferReactorNettyCodec
public AbstractNioBufferReactorNettyCodec()
-
-
Method Details
-
decode
Description copied from interface:ReactorNettyCodec
Decode the inputByteBuf
into one or moreMessages
.- Specified by:
decode
in interfaceReactorNettyCodec<P>
- Parameters:
inputBuffer
- the input buffer to decode from- Returns:
- 0 or more decoded messages
-
encode
Description copied from interface:ReactorNettyCodec
Encode the givenMessage
to the outputByteBuf
.- Specified by:
encode
in interfaceReactorNettyCodec<P>
- Parameters:
message
- the message to encodeoutputBuffer
- the buffer to write to
-
decodeInternal
-
encodeInternal
-