@UnstableApi public class BinaryMemcacheObjectAggregator extends AbstractMemcacheObjectAggregator<BinaryMemcacheMessage>
BinaryMemcacheMessages and MemcacheContent into FullBinaryMemcacheRequests
or FullBinaryMemcacheResponses.ChannelHandler.Sharable| Constructor and Description |
|---|
BinaryMemcacheObjectAggregator(int maxContentLength) |
| Modifier and Type | Method and Description |
|---|---|
protected FullMemcacheMessage |
beginAggregation(BinaryMemcacheMessage start,
ByteBuf content)
Creates a new aggregated message from the specified start message and the specified content.
|
protected boolean |
isStartMessage(MemcacheObject msg)
Returns
true if and only if the specified message is a start message. |
private static FullBinaryMemcacheRequest |
toFullRequest(BinaryMemcacheRequest request,
ByteBuf content) |
private static FullBinaryMemcacheResponse |
toFullResponse(BinaryMemcacheResponse response,
ByteBuf content) |
closeAfterContinueResponse, ignoreContentAfterContinueResponse, isAggregated, isContentLengthInvalid, isContentMessage, isLastContentMessage, newContinueResponseacceptInboundMessage, aggregate, channelInactive, channelReadComplete, ctx, decode, finishAggregation, handleOversizedMessage, handlerAdded, handlerRemoved, isHandlingOversizedMessage, maxContentLength, maxCumulationBufferComponents, setMaxCumulationBufferComponentschannelReadchannelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggeredensureNotSharable, isSharablepublic BinaryMemcacheObjectAggregator(int maxContentLength)
protected boolean isStartMessage(MemcacheObject msg) throws java.lang.Exception
MessageAggregatortrue if and only if the specified message is a start message. Typically, this method is
implemented as a single return statement with instanceof:
return msg instanceof MyStartMessage;
isStartMessage in class MessageAggregator<MemcacheObject,BinaryMemcacheMessage,MemcacheContent,FullMemcacheMessage>java.lang.Exceptionprotected FullMemcacheMessage beginAggregation(BinaryMemcacheMessage start, ByteBuf content) throws java.lang.Exception
MessageAggregatorByteBufHolder, its content is appended to the specified content.
This aggregator will continue to append the received content to the specified content.beginAggregation in class MessageAggregator<MemcacheObject,BinaryMemcacheMessage,MemcacheContent,FullMemcacheMessage>java.lang.Exceptionprivate static FullBinaryMemcacheRequest toFullRequest(BinaryMemcacheRequest request, ByteBuf content)
private static FullBinaryMemcacheResponse toFullResponse(BinaryMemcacheResponse response, ByteBuf content)