private final class BinaryMemcacheClientCodec.Decoder extends BinaryMemcacheResponseDecoder
AbstractBinaryMemcacheDecoder.StateByteToMessageDecoder.CumulatorChannelHandler.SharableDEFAULT_MAX_CHUNK_SIZECOMPOSITE_CUMULATOR, MERGE_CUMULATOR| Constructor and Description |
|---|
Decoder(int chunkSize) |
| Modifier and Type | Method and Description |
|---|---|
void |
channelInactive(ChannelHandlerContext ctx)
When the channel goes inactive, release all frames to prevent data leaks.
|
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
buildInvalidMessage, decodeHeaderresetDecoderactualReadableBytes, callDecode, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggeredchannelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaughtensureNotSharable, handlerAdded, isSharableclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandlerAddedprotected void decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) throws java.lang.Exception
ByteToMessageDecoderByteBuf to an other. This method will be called till either the input
ByteBuf has nothing to read when return from this method or till nothing was read from the input
ByteBuf.decode in class AbstractBinaryMemcacheDecoder<BinaryMemcacheResponse>ctx - the ChannelHandlerContext which this ByteToMessageDecoder belongs toin - the ByteBuf from which to read dataout - the List to which decoded messages should be addedjava.lang.Exception - is thrown if an error occurspublic void channelInactive(ChannelHandlerContext ctx) throws java.lang.Exception
AbstractBinaryMemcacheDecoderchannelInactive in interface ChannelInboundHandlerchannelInactive in class AbstractBinaryMemcacheDecoder<BinaryMemcacheResponse>ctx - handler contextjava.lang.Exception