public class StompReactorNettyCodec extends AbstractNioBufferReactorNettyCodec<byte[]>
Modifier and Type | Field and Description |
---|---|
private StompDecoder |
decoder |
private StompEncoder |
encoder |
Constructor and Description |
---|
StompReactorNettyCodec() |
StompReactorNettyCodec(StompDecoder decoder) |
StompReactorNettyCodec(StompDecoder decoder,
StompEncoder encoder) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Message<byte[]>> |
decodeInternal(java.nio.ByteBuffer nioBuffer) |
protected java.nio.ByteBuffer |
encodeInternal(Message<byte[]> message) |
decode, encode
private final StompDecoder decoder
private final StompEncoder encoder
public StompReactorNettyCodec()
public StompReactorNettyCodec(StompDecoder decoder)
public StompReactorNettyCodec(StompDecoder decoder, StompEncoder encoder)
protected java.util.List<Message<byte[]>> decodeInternal(java.nio.ByteBuffer nioBuffer)
decodeInternal
in class AbstractNioBufferReactorNettyCodec<byte[]>
protected java.nio.ByteBuffer encodeInternal(Message<byte[]> message)
encodeInternal
in class AbstractNioBufferReactorNettyCodec<byte[]>