io.netty.handler.codec.memcache.binary

Class BinaryMemcacheObjectAggregator

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

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

io.netty.handler.codec.MessageAggregator<MemcacheObject,H,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 io.netty.channel.ChannelHandler

ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
BinaryMemcacheObjectAggregator(int maxContentLength)

Method Summary

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.

Methods inherited from class io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator

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

Methods inherited from class io.netty.handler.codec.MessageAggregator

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

Methods inherited from class io.netty.handler.codec.MessageToMessageDecoder

channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Constructor Detail

BinaryMemcacheObjectAggregator

public BinaryMemcacheObjectAggregator(int maxContentLength)

Method Detail

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