public class BinaryMemcacheObjectAggregator extends AbstractMemcacheObjectAggregator<BinaryMemcacheMessage>
BinaryMemcacheMessage
s and MemcacheContent
into FullBinaryMemcacheRequest
s
or FullBinaryMemcacheResponse
s.ChannelHandler.Sharable, ChannelHandler.Skip
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. |
contentLength, hasContentLength, isAggregated, isContentMessage, isLastContentMessage, newContinueResponse
acceptInboundMessage, aggregate, channelInactive, ctx, decode, finishAggregation, handleOversizedMessage, handlerAdded, handlerRemoved, isHandlingOversizedMessage, maxContentLength, maxCumulationBufferComponents, setMaxCumulationBufferComponents
channelRead
bind, channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, close, connect, deregister, disconnect, exceptionCaught, flush, isSharable, read, userEventTriggered, write
public BinaryMemcacheObjectAggregator(int maxContentLength)
protected boolean isStartMessage(MemcacheObject msg) throws Exception
MessageAggregator
true
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>
Exception
protected FullMemcacheMessage beginAggregation(BinaryMemcacheMessage start, ByteBuf content) throws Exception
MessageAggregator
ByteBufHolder
, 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>
Exception
Copyright © 2008–2015 The Netty Project. All rights reserved.