@UnstableApi public final class RedisArrayAggregator extends MessageToMessageDecoder<RedisMessage>
RedisMessage
部分聚合为ArrayRedisMessage
。
该解码器应与RedisDecoder
一起使用。
ChannelHandler.Sharable
Constructor and Description |
---|
RedisArrayAggregator() |
Modifier and Type | Method and Description |
---|---|
protected void |
decode(ChannelHandlerContext ctx, RedisMessage msg, java.util.List<java.lang.Object> out)
从一条消息解码到另一条消息。
|
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded, handlerRemoved
protected void decode(ChannelHandlerContext ctx, RedisMessage msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageDecoder
decode
在课堂上
MessageToMessageDecoder<RedisMessage>
ctx
- 这MessageToMessageDecoder
所属的ChannelHandlerContext
msg
- 解码到另一个的消息
out
- 应该添加解码消息的
List
java.lang.Exception
- 发生错误时抛出
Copyright © 2008–2018 The Netty Project. All rights reserved.