Class BinaryMemcacheObjectAggregator

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.MessageToMessageDecoder<MemcacheObject>

io.netty.handler.codec.MessageAggregator<MemcacheObject, BinaryMemcacheMessage, MemcacheContent, FullMemcacheMessage>

io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator<BinaryMemcacheMessage>

io.netty.handler.codec.memcache.binary.BinaryMemcacheObjectAggregator

All Implemented Interfaces:

ChannelHandler, ChannelInboundHandler

@UnstableApi
public class BinaryMemcacheObjectAggregator
extends AbstractMemcacheObjectAggregator<BinaryMemcacheMessage>

An object aggregator for the memcache binary protocol. It aggregates BinaryMemcacheMessages and MemcacheContent into FullBinaryMemcacheRequests or FullBinaryMemcacheResponses.

Nested Class Summary

Nested classes/interfaces inherited from interface ChannelHandler

ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor	Description
BinaryMemcacheObjectAggregator(int maxContentLength)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class AbstractMemcacheObjectAggregator

closeAfterContinueResponse, ignoreContentAfterContinueResponse, isAggregated, isContentLengthInvalid, isContentMessage, isLastContentMessage, newContinueResponse

Methods inherited from class MessageAggregator

acceptInboundMessage, aggregate, channelInactive, channelReadComplete, ctx, decode, finishAggregation, handleOversizedMessage, handlerAdded, handlerRemoved, isHandlingOversizedMessage, maxContentLength, maxCumulationBufferComponents, releaseCurrentMessage, setMaxCumulationBufferComponents

Methods inherited from class MessageToMessageDecoder

channelRead

Methods inherited from class ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BinaryMemcacheObjectAggregator

public BinaryMemcacheObjectAggregator(int maxContentLength)

Method Details

isStartMessage

protected boolean isStartMessage(MemcacheObject msg)
                          throws Exception

Description copied from class: MessageAggregator

Returns 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;

Specified by:

isStartMessage in class MessageAggregator<MemcacheObject, BinaryMemcacheMessage, MemcacheContent, FullMemcacheMessage>

Throws:

Exception

beginAggregation

protected FullMemcacheMessage beginAggregation(BinaryMemcacheMessage start,
 ByteBuf content)
                                        throws Exception

Description copied from class: MessageAggregator

Creates a new aggregated message from the specified start message and the specified content. If the start message implements ByteBufHolder, its content is appended to the specified content. This aggregator will continue to append the received content to the specified content.

Specified by:

beginAggregation in class MessageAggregator<MemcacheObject, BinaryMemcacheMessage, MemcacheContent, FullMemcacheMessage>

Throws:

Exception

toFullRequest

private static FullBinaryMemcacheRequest toFullRequest(BinaryMemcacheRequest request,
 ByteBuf content)

toFullResponse

private static FullBinaryMemcacheResponse toFullResponse(BinaryMemcacheResponse response,
 ByteBuf content)