public class BinaryMemcacheResponseDecoder extends AbstractBinaryMemcacheDecoder<BinaryMemcacheResponse>
The decoder which takes care of decoding the response headers.
DEFAULT_MAX_CHUNK_SIZE
Constructor and Description |
---|
BinaryMemcacheResponseDecoder() |
BinaryMemcacheResponseDecoder(int chunkSize) |
Modifier and Type | Method and Description |
---|---|
protected BinaryMemcacheResponse |
buildInvalidMessage()
Helper method to create a upstream message when the incoming parsing did fail.
|
protected BinaryMemcacheResponse |
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 BinaryMemcacheResponseDecoder()
public BinaryMemcacheResponseDecoder(int chunkSize)
protected BinaryMemcacheResponse decodeHeader(io.netty.buffer.ByteBuf in)
AbstractBinaryMemcacheDecoder
Decode and return the parsed BinaryMemcacheMessage
.
decodeHeader
in class AbstractBinaryMemcacheDecoder<BinaryMemcacheResponse>
in
- the incoming buffer.protected BinaryMemcacheResponse buildInvalidMessage()
AbstractBinaryMemcacheDecoder
Helper method to create a upstream message when the incoming parsing did fail.
buildInvalidMessage
in class AbstractBinaryMemcacheDecoder<BinaryMemcacheResponse>
Copyright © 2018 Couchbase, Inc.. All rights reserved.