@UnstableApi public class BinaryMemcacheObjectAggregator extends AbstractMemcacheObjectAggregator<BinaryMemcacheMessage>
BinaryMemcacheMessages and MemcacheContent into FullBinaryMemcacheRequests
or FullBinaryMemcacheResponses.| Constructor and Description |
|---|
BinaryMemcacheObjectAggregator(int maxContentLength) |
| Modifier and Type | Method and Description |
|---|---|
protected FullMemcacheMessage |
beginAggregation(BinaryMemcacheMessage start,
io.netty.buffer.ByteBuf content) |
protected boolean |
isStartMessage(MemcacheObject msg) |
closeAfterContinueResponse, ignoreContentAfterContinueResponse, isAggregated, isContentLengthInvalid, isContentMessage, isLastContentMessage, newContinueResponseacceptInboundMessage, aggregate, channelInactive, channelReadComplete, ctx, decode, finishAggregation, handleOversizedMessage, handlerAdded, handlerRemoved, isHandlingOversizedMessage, maxContentLength, maxCumulationBufferComponents, setMaxCumulationBufferComponentspublic BinaryMemcacheObjectAggregator(int maxContentLength)
protected boolean isStartMessage(MemcacheObject msg) throws Exception
isStartMessage in class io.netty.handler.codec.MessageAggregator<MemcacheObject,BinaryMemcacheMessage,MemcacheContent,FullMemcacheMessage>Exceptionprotected FullMemcacheMessage beginAggregation(BinaryMemcacheMessage start, io.netty.buffer.ByteBuf content) throws Exception
beginAggregation in class io.netty.handler.codec.MessageAggregator<MemcacheObject,BinaryMemcacheMessage,MemcacheContent,FullMemcacheMessage>ExceptionCopyright © 2008–2020 The Netty Project. All rights reserved.