Package io.kroxylicious.proxy.internal.codec

Class KafkaResponseEncoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelOutboundHandlerAdapter

io.netty.handler.codec.MessageToByteEncoder<ResponseFrame>

io.kroxylicious.proxy.internal.codec.KafkaResponseEncoder

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelOutboundHandler

public class KafkaResponseEncoder
extends io.netty.handler.codec.MessageToByteEncoder<ResponseFrame>

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor	Description
KafkaResponseEncoder(KafkaMessageListener listener)

Method Summary

Modifier and Type	Method	Description
protected io.netty.buffer.ByteBuf	allocateBuffer(io.netty.channel.ChannelHandlerContext ctx, ResponseFrame msg, boolean preferDirect)	This has been overridden in order to use Frame.estimateEncodedSize() to pre-size correctly the holding buffer and save expensive enlarging to happen under the hood, during the encoding process.
protected void	encode(io.netty.channel.ChannelHandlerContext ctx, ResponseFrame frame, io.netty.buffer.ByteBuf out)
protected org.slf4j.Logger	log()

Methods inherited from class io.netty.handler.codec.MessageToByteEncoder

acceptOutboundMessage, isPreferDirect, write

Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter

bind, close, connect, deregister, disconnect, flush, read

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

exceptionCaught, handlerAdded, handlerRemoved

Constructor Details

KafkaResponseEncoder

public KafkaResponseEncoder(@Nullable
 KafkaMessageListener listener)

Method Details

log

protected org.slf4j.Logger log()

allocateBuffer

protected io.netty.buffer.ByteBuf allocateBuffer(io.netty.channel.ChannelHandlerContext ctx,
 ResponseFrame msg,
 boolean preferDirect)
                                          throws Exception

This has been overridden in order to use Frame.estimateEncodedSize() to pre-size correctly the holding buffer and save expensive enlarging to happen under the hood, during the encoding process.

Overrides:

allocateBuffer in class io.netty.handler.codec.MessageToByteEncoder<F extends Frame>

Throws:

Exception

encode

protected void encode(io.netty.channel.ChannelHandlerContext ctx,
 ResponseFrame frame,
 io.netty.buffer.ByteBuf out)
               throws Exception

Specified by:

encode in class io.netty.handler.codec.MessageToByteEncoder<F extends Frame>

Throws:

Exception