@UnstableApi public class BinaryMemcacheRequestDecoder extends AbstractBinaryMemcacheDecoder<BinaryMemcacheRequest>
DEFAULT_MAX_CHUNK_SIZE
Constructor and Description |
---|
BinaryMemcacheRequestDecoder() |
BinaryMemcacheRequestDecoder(int chunkSize) |
Modifier and Type | Method and Description |
---|---|
protected BinaryMemcacheRequest |
buildInvalidMessage()
Helper method to create a upstream message when the incoming parsing did fail.
|
protected BinaryMemcacheRequest |
decodeHeader(io.netty.buffer.ByteBuf in)
Decode and return the parsed
BinaryMemcacheMessage . |
channelInactive, decode, resetDecoder
actualReadableBytes, callDecode, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
ensureNotSharable, handlerAdded, isSharable
public BinaryMemcacheRequestDecoder()
public BinaryMemcacheRequestDecoder(int chunkSize)
protected BinaryMemcacheRequest decodeHeader(io.netty.buffer.ByteBuf in)
AbstractBinaryMemcacheDecoder
BinaryMemcacheMessage
.decodeHeader
in class AbstractBinaryMemcacheDecoder<BinaryMemcacheRequest>
in
- the incoming buffer.protected BinaryMemcacheRequest buildInvalidMessage()
AbstractBinaryMemcacheDecoder
buildInvalidMessage
in class AbstractBinaryMemcacheDecoder<BinaryMemcacheRequest>
Copyright © 2008–2021 The Netty Project. All rights reserved.