Class RedisBulkStringAggregator

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

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

io.netty.handler.codec.MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

io.netty.handler.codec.redis.RedisBulkStringAggregator

All Implemented Interfaces:

ChannelHandler, ChannelInboundHandler

@UnstableApi
public final class RedisBulkStringAggregator
extends MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

A ChannelHandler that aggregates an BulkStringHeaderRedisMessage and its following BulkStringRedisContents into a single FullBulkStringRedisMessage with no following BulkStringRedisContents. It is useful when you don't want to take care of RedisMessages whose transfer encoding is 'chunked'. Insert this handler after RedisDecoder in the ChannelPipeline:

ChannelPipeline p = ...;
...
p.addLast("encoder", new RedisEncoder());
p.addLast("decoder", new RedisDecoder());
p.addLast("aggregator", new RedisBulkStringAggregator());
...
p.addLast("handler", new HttpRequestHandler());

Be aware that you need to have the RedisEncoder before the RedisBulkStringAggregator in the ChannelPipeline.

Nested Class Summary

Nested classes/interfaces inherited from interface ChannelHandler

ChannelHandler.Sharable

Modifier and Type	Interface	Description
static @interface	ChannelHandler.Sharable	Indicates that the same instance of the annotated ChannelHandler can be added to one or more ChannelPipelines multiple times without a race condition.

Constructor Summary

Constructors

Constructor	Description
RedisBulkStringAggregator()	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
protected FullBulkStringRedisMessage	beginAggregation(BulkStringHeaderRedisMessage start, ByteBuf content)	Creates a new aggregated message from the specified start message and the specified content.
protected boolean	closeAfterContinueResponse(Object msg)	Determine if the channel should be closed after the result of MessageAggregator.newContinueResponse(Object, int, ChannelPipeline) is written.
protected boolean	ignoreContentAfterContinueResponse(Object msg)	Determine if all objects for the current request/response should be ignored or not.
protected boolean	isAggregated(RedisMessage msg)	Returns true if and only if the specified message is already aggregated.
protected boolean	isContentLengthInvalid(BulkStringHeaderRedisMessage start, int maxContentLength)	Determine if the message start's content length is known, and if it greater than maxContentLength.
protected boolean	isContentMessage(RedisMessage msg)	Returns true if and only if the specified message is a content message.
protected boolean	isLastContentMessage(BulkStringRedisContent msg)	Returns true if and only if the specified message is the last content message.
protected boolean	isStartMessage(RedisMessage msg)	Returns true if and only if the specified message is a start message.
protected Object	newContinueResponse(BulkStringHeaderRedisMessage start, int maxContentLength, ChannelPipeline pipeline)	Returns the 'continue response' for the specified start message if necessary.

Methods inherited from class MessageAggregator

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

Modifier and Type	Method	Description
boolean	acceptInboundMessage(Object msg)	Returns true if the given message should be handled.
protected void	aggregate(FullBulkStringRedisMessage aggregated, BulkStringRedisContent content)	Transfers the information provided by the specified content message to the specified aggregated message.
void	channelInactive(ChannelHandlerContext ctx)	Calls ChannelHandlerContext.fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelReadComplete(ChannelHandlerContext ctx)	Calls ChannelHandlerContext.fireChannelReadComplete() to forward to the next ChannelInboundHandler in the ChannelPipeline.
protected final ChannelHandlerContext	ctx()
protected void	decode(ChannelHandlerContext ctx, RedisMessage msg, List<Object> out)	Decode from one message to an other.
protected void	finishAggregation(FullBulkStringRedisMessage aggregated)	Invoked when the specified aggregated message is about to be passed to the next handler in the pipeline.
protected void	handleOversizedMessage(ChannelHandlerContext ctx, BulkStringHeaderRedisMessage oversized)	Invoked when an incoming request exceeds the maximum content length.
void	handlerAdded(ChannelHandlerContext ctx)	Do nothing by default, sub-classes may override this method.
void	handlerRemoved(ChannelHandlerContext ctx)	Do nothing by default, sub-classes may override this method.
final boolean	isHandlingOversizedMessage()	Deprecated. This method will be removed in future releases.
final int	maxContentLength()	Returns the maximum allowed length of the aggregated message in bytes.
final int	maxCumulationBufferComponents()	Returns the maximum number of components in the cumulation buffer.
protected final void	releaseCurrentMessage()
final void	setMaxCumulationBufferComponents(int maxCumulationBufferComponents)	Sets the maximum number of components in the cumulation buffer.

Methods inherited from class MessageToMessageDecoder

channelRead

Modifier and Type	Method	Description
void	channelRead(ChannelHandlerContext ctx, Object msg)	Calls ChannelHandlerContext.fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.

Methods inherited from class ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Modifier and Type	Method	Description
void	channelActive(ChannelHandlerContext ctx)	Calls ChannelHandlerContext.fireChannelActive() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelRegistered(ChannelHandlerContext ctx)	Calls ChannelHandlerContext.fireChannelRegistered() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelUnregistered(ChannelHandlerContext ctx)	Calls ChannelHandlerContext.fireChannelUnregistered() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelWritabilityChanged(ChannelHandlerContext ctx)	Calls ChannelHandlerContext.fireChannelWritabilityChanged() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	exceptionCaught(ChannelHandlerContext ctx, Throwable cause)	Calls ChannelHandlerContext.fireExceptionCaught(Throwable) to forward to the next ChannelHandler in the ChannelPipeline.
void	userEventTriggered(ChannelHandlerContext ctx, Object evt)	Calls ChannelHandlerContext.fireUserEventTriggered(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.

Methods inherited from class ChannelHandlerAdapter

ensureNotSharable, isSharable

Modifier and Type	Method	Description
protected void	ensureNotSharable()	Throws IllegalStateException if ChannelHandlerAdapter.isSharable() returns true
boolean	isSharable()	Return true if the implementation is ChannelHandler.Sharable and so can be added to different ChannelPipelines.

Methods inherited from class Object

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

Constructor Details

RedisBulkStringAggregator

public RedisBulkStringAggregator()

Creates a new instance.

Method Details

isStartMessage

protected boolean isStartMessage(RedisMessage 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<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Throws:

Exception

isContentMessage

protected boolean isContentMessage(RedisMessage msg)
                            throws Exception

Description copied from class: MessageAggregator

Returns true if and only if the specified message is a content message. Typically, this method is implemented as a single return statement with instanceof:

return msg instanceof MyContentMessage;

Specified by:

isContentMessage in class MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Throws:

Exception

isLastContentMessage

protected boolean isLastContentMessage(BulkStringRedisContent msg)
                                throws Exception

Description copied from class: MessageAggregator

Returns true if and only if the specified message is the last content message. Typically, this method is implemented as a single return statement with instanceof:

return msg instanceof MyLastContentMessage;

or with instanceof and boolean field check:

return msg instanceof MyContentMessage invalid input: '&'invalid input: '&' msg.isLastFragment();

Specified by:

isLastContentMessage in class MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Throws:

Exception

isAggregated

protected boolean isAggregated(RedisMessage msg)
                        throws Exception

Description copied from class: MessageAggregator

Returns true if and only if the specified message is already aggregated. If this method returns true, this handler will simply forward the message to the next handler as-is.

Specified by:

isAggregated in class MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Throws:

Exception

isContentLengthInvalid

protected boolean isContentLengthInvalid(BulkStringHeaderRedisMessage start,
 int maxContentLength)
                                  throws Exception

Description copied from class: MessageAggregator

Determine if the message start's content length is known, and if it greater than maxContentLength.

Specified by:

isContentLengthInvalid in class MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Parameters:

start - The message which may indicate the content length.

maxContentLength - The maximum allowed content length.

Returns:

true if the message start's content length is known, and if it greater than maxContentLength. false otherwise.

Throws:

Exception

newContinueResponse

protected Object newContinueResponse(BulkStringHeaderRedisMessage start,
 int maxContentLength,
 ChannelPipeline pipeline)
                              throws Exception

Description copied from class: MessageAggregator

Returns the 'continue response' for the specified start message if necessary. For example, this method is useful to handle an HTTP 100-continue header.

Specified by:

newContinueResponse in class MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Returns:

the 'continue response', or null if there's no message to send

Throws:

Exception

closeAfterContinueResponse

protected boolean closeAfterContinueResponse(Object msg)
                                      throws Exception

Description copied from class: MessageAggregator

Determine if the channel should be closed after the result of MessageAggregator.newContinueResponse(Object, int, ChannelPipeline) is written.

Specified by:

closeAfterContinueResponse in class MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Parameters:

msg - The return value from MessageAggregator.newContinueResponse(Object, int, ChannelPipeline).

Returns:

true if the channel should be closed after the result of MessageAggregator.newContinueResponse(Object, int, ChannelPipeline) is written. false otherwise.

Throws:

Exception

ignoreContentAfterContinueResponse

protected boolean ignoreContentAfterContinueResponse(Object msg)
                                              throws Exception

Description copied from class: MessageAggregator

Determine if all objects for the current request/response should be ignored or not. Messages will stop being ignored the next time MessageAggregator.isContentMessage(Object) returns true.

Specified by:

ignoreContentAfterContinueResponse in class MessageAggregator<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Parameters:

msg - The return value from MessageAggregator.newContinueResponse(Object, int, ChannelPipeline).

Returns:

true if all objects for the current request/response should be ignored or not. false otherwise.

Throws:

Exception

beginAggregation

protected FullBulkStringRedisMessage beginAggregation(BulkStringHeaderRedisMessage 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<RedisMessage, BulkStringHeaderRedisMessage, BulkStringRedisContent, FullBulkStringRedisMessage>

Throws:

Exception