@UnstableApi public final class RedisArrayAggregator extends MessageToMessageDecoder<RedisMessage>
RedisMessage parts into ArrayRedisMessage. This decoder
should be used together with RedisDecoder.ChannelHandler.Sharable| 构造器和说明 |
|---|
RedisArrayAggregator() |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
decode(ChannelHandlerContext ctx,
RedisMessage msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
acceptInboundMessage, channelReadchannelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharableclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandlerAdded, handlerRemovedprotected void decode(ChannelHandlerContext ctx, RedisMessage msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageDecoderdecode 在类中 MessageToMessageDecoder<RedisMessage>ctx - the ChannelHandlerContext which this MessageToMessageDecoder belongs tomsg - the message to decode to an other oneout - the List to which decoded messages should be addedjava.lang.Exception - is thrown if an error occurs