JavaScript is disabled on your browser.

Class RedisArrayAggregator

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

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

io.netty.handler.codec.redis.RedisArrayAggregator

All Implemented Interfaces:: ChannelHandler, ChannelInboundHandler

@UnstableApi public final class RedisArrayAggregator extends MessageToMessageDecoder<RedisMessage>

Aggregates RedisMessage parts into ArrayRedisMessage. This decoder should be used together with RedisDecoder.

Nested Class Summary

Nested classes/interfaces inherited from interface ChannelHandler
ChannelHandler.Sharable
Constructor Summary

Constructors

Constructor

Description

RedisArrayAggregator()
Method Summary

Modifier and Type

Method

Description

protected void

decode (ChannelHandlerContext ctx, RedisMessage msg, List<Object> out)

Decode from one message to an other.

Methods inherited from class MessageToMessageDecoder
acceptInboundMessage, channelRead, channelReadComplete

Methods inherited from class ChannelInboundHandlerAdapter
channelActive, channelInactive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ChannelHandler
handlerAdded, handlerRemoved

Constructor Details
- RedisArrayAggregator
  
  public RedisArrayAggregator()
Method Details
- decode
  
  protected void decode(ChannelHandlerContext ctx, RedisMessage msg, List<Object> out) throws Exception
  
  Description copied from class: MessageToMessageDecoder
  
  Decode from one message to an other. This method will be called for each written message that can be handled by this decoder.
  
  Specified by:
  
  decode in class MessageToMessageDecoder<RedisMessage>
  
  Parameters:
  
  ctx - the ChannelHandlerContext which this MessageToMessageDecoder belongs to
  
  msg - the message to decode to an other one
  
  out - the List to which decoded messages should be added
  
  Throws:
  
  Exception - is thrown if an error occurs